From c024f2431588bc25f63e2d2be21bfcebe08ebdaa Mon Sep 17 00:00:00 2001
From: James Houlahan <james.houlahan@proton.ch>
Date: Sun, 26 Feb 2023 14:51:24 +0100
Subject: [PATCH] feat: Add share events

---
 event_drive.go       | 66 ++++++++++++++++++++++++++++++++++++++------
 event_drive_types.go |  2 +-
 2 files changed, 59 insertions(+), 9 deletions(-)

diff --git a/event_drive.go b/event_drive.go
index e1df224..5e625d2 100644
--- a/event_drive.go
+++ b/event_drive.go
@@ -20,18 +20,32 @@ func (c *Client) GetLatestVolumeEventID(ctx context.Context, volumeID string) (s
 	return res.EventID, nil
 }
 
-func (c *Client) GetVolumeEvent(ctx context.Context, volumeID, eventID string) (VolumeEvent, error) {
+func (c *Client) GetLatestShareEventID(ctx context.Context, shareID string) (string, error) {
+	var res struct {
+		EventID string
+	}
+
+	if err := c.do(ctx, func(r *resty.Request) (*resty.Response, error) {
+		return r.SetResult(&res).Get("/drive/shares/" + shareID + "/events/latest")
+	}); err != nil {
+		return "", err
+	}
+
+	return res.EventID, nil
+}
+
+func (c *Client) GetVolumeEvent(ctx context.Context, volumeID, eventID string) (DriveEvent, error) {
 	event, more, err := c.getVolumeEvent(ctx, volumeID, eventID)
 	if err != nil {
-		return VolumeEvent{}, err
+		return DriveEvent{}, err
 	}
 
 	for more {
-		var next VolumeEvent
+		var next DriveEvent
 
 		next, more, err = c.getVolumeEvent(ctx, volumeID, event.EventID)
 		if err != nil {
-			return VolumeEvent{}, err
+			return DriveEvent{}, err
 		}
 
 		event.Events = append(event.Events, next.Events...)
@@ -40,9 +54,29 @@ func (c *Client) GetVolumeEvent(ctx context.Context, volumeID, eventID string) (
 	return event, nil
 }
 
-func (c *Client) getVolumeEvent(ctx context.Context, volumeID, eventID string) (VolumeEvent, bool, error) {
+func (c *Client) GetShareEvent(ctx context.Context, shareID, eventID string) (DriveEvent, error) {
+	event, more, err := c.getShareEvent(ctx, shareID, eventID)
+	if err != nil {
+		return DriveEvent{}, err
+	}
+
+	for more {
+		var next DriveEvent
+
+		next, more, err = c.getShareEvent(ctx, shareID, event.EventID)
+		if err != nil {
+			return DriveEvent{}, err
+		}
+
+		event.Events = append(event.Events, next.Events...)
+	}
+
+	return event, nil
+}
+
+func (c *Client) getVolumeEvent(ctx context.Context, volumeID, eventID string) (DriveEvent, bool, error) {
 	var res struct {
-		VolumeEvent
+		DriveEvent
 
 		More Bool
 	}
@@ -50,8 +84,24 @@ func (c *Client) getVolumeEvent(ctx context.Context, volumeID, eventID string) (
 	if err := c.do(ctx, func(r *resty.Request) (*resty.Response, error) {
 		return r.SetResult(&res).Get("/drive/volumes/" + volumeID + "/events/" + eventID)
 	}); err != nil {
-		return VolumeEvent{}, false, err
+		return DriveEvent{}, false, err
 	}
 
-	return res.VolumeEvent, bool(res.More), nil
+	return res.DriveEvent, bool(res.More), nil
+}
+
+func (c *Client) getShareEvent(ctx context.Context, shareID, eventID string) (DriveEvent, bool, error) {
+	var res struct {
+		DriveEvent
+
+		More Bool
+	}
+
+	if err := c.do(ctx, func(r *resty.Request) (*resty.Response, error) {
+		return r.SetResult(&res).Get("/drive/shares/" + shareID + "/events/" + eventID)
+	}); err != nil {
+		return DriveEvent{}, false, err
+	}
+
+	return res.DriveEvent, bool(res.More), nil
 }
diff --git a/event_drive_types.go b/event_drive_types.go
index a15fa7f..b6355a8 100644
--- a/event_drive_types.go
+++ b/event_drive_types.go
@@ -1,6 +1,6 @@
 package proton
 
-type VolumeEvent struct {
+type DriveEvent struct {
 	EventID string
 
 	Events []LinkEvent