From 2090ae9f3912031eb28880e13690bebd718e9afa Mon Sep 17 00:00:00 2001 From: Derrick Hammer Date: Wed, 18 Sep 2024 10:56:59 -0400 Subject: [PATCH 1/2] refactor(event): rename StorageObjectUploadedEvent to StorageObjectPinnedEvent for consistency --- event/storage.go | 42 ------------------------------------------ event/storage_pin.go | 42 ++++++++++++++++++++++++++++++++++++++++++ 2 files changed, 42 insertions(+), 42 deletions(-) delete mode 100644 event/storage.go create mode 100644 event/storage_pin.go diff --git a/event/storage.go b/event/storage.go deleted file mode 100644 index c86d86ee..00000000 --- a/event/storage.go +++ /dev/null @@ -1,42 +0,0 @@ -package event - -import ( - "go.lumeweb.com/portal/core" - "go.lumeweb.com/portal/db/models" -) - -const ( - EVENT_STORAGE_OBJECT_UPLOADED = "storage.object.uploaded" -) - -func init() { - core.RegisterEvent(EVENT_STORAGE_OBJECT_UPLOADED, &StorageObjectUploadedEvent{}) -} - -type StorageObjectUploadedEvent struct { - core.Event -} - -func (e *StorageObjectUploadedEvent) SetPin(metadata *models.Pin) { - e.Set("pin", metadata) -} - -func (e StorageObjectUploadedEvent) Pin() *models.Pin { - return e.Get("pin").(*models.Pin) -} - -func (e *StorageObjectUploadedEvent) SetIP(ip string) { - e.Set("ip", ip) -} - -func (e StorageObjectUploadedEvent) IP() string { - return e.Get("ip").(string) -} - -func FireStorageObjectUploadedEvent(ctx core.Context, pin *models.Pin, ip string) error { - return Fire[*StorageObjectUploadedEvent](ctx, EVENT_STORAGE_OBJECT_UPLOADED, func(evt *StorageObjectUploadedEvent) error { - evt.SetPin(pin) - evt.SetIP(ip) - return nil - }) -} diff --git a/event/storage_pin.go b/event/storage_pin.go new file mode 100644 index 00000000..7c356761 --- /dev/null +++ b/event/storage_pin.go @@ -0,0 +1,42 @@ +package event + +import ( + "go.lumeweb.com/portal/core" + "go.lumeweb.com/portal/db/models" +) + +const ( + EVENT_STORAGE_OBJECT_PINNED = "storage.object.pinned" +) + +func init() { + core.RegisterEvent(EVENT_STORAGE_OBJECT_PINNED, &StorageObjectPinnedEvent{}) +} + +type StorageObjectPinnedEvent struct { + core.Event +} + +func (e *StorageObjectPinnedEvent) SetPin(metadata *models.Pin) { + e.Set("pin", metadata) +} + +func (e StorageObjectPinnedEvent) Pin() *models.Pin { + return e.Get("pin").(*models.Pin) +} + +func (e *StorageObjectPinnedEvent) SetIP(ip string) { + e.Set("ip", ip) +} + +func (e StorageObjectPinnedEvent) IP() string { + return e.Get("ip").(string) +} + +func FireStorageObjectUploadedEvent(ctx core.Context, pin *models.Pin, ip string) error { + return Fire[*StorageObjectPinnedEvent](ctx, EVENT_STORAGE_OBJECT_PINNED, func(evt *StorageObjectPinnedEvent) error { + evt.SetPin(pin) + evt.SetIP(ip) + return nil + }) +} From a680dce0f4391ef2acc7af06d64de5de1244d731 Mon Sep 17 00:00:00 2001 From: Derrick Hammer Date: Wed, 18 Sep 2024 10:57:14 -0400 Subject: [PATCH 2/2] feat(event): add StorageObjectUnpinnedEvent --- event/storage_unpin.go | 36 ++++++++++++++++++++++++++++++++++++ 1 file changed, 36 insertions(+) create mode 100644 event/storage_unpin.go diff --git a/event/storage_unpin.go b/event/storage_unpin.go new file mode 100644 index 00000000..47fbe0ca --- /dev/null +++ b/event/storage_unpin.go @@ -0,0 +1,36 @@ +package event + +import ( + "go.lumeweb.com/portal/core" + "go.lumeweb.com/portal/db/models" +) + +const ( + EVENT_STORAGE_OBJECT_UNPINNED = "storage.object.unpinned" +) + +func init() { + core.RegisterEvent(EVENT_STORAGE_OBJECT_UNPINNED, &StorageObjectPinnedEvent{}) +} + +type StorageObjectUnpinnedEvent struct { + core.Event +} + +func (e *StorageObjectUnpinnedEvent) SetPin(metadata *models.Pin) { + e.Set("pin", metadata) +} + +func (e StorageObjectUnpinnedEvent) Pin() *models.Pin { + return e.Get("pin").(*models.Pin) +} +func (e StorageObjectUnpinnedEvent) IP() string { + return e.Get("ip").(string) +} + +func FireStorageObjectUnpinnedEvent(ctx core.Context, pin *models.Pin) error { + return Fire[*StorageObjectPinnedEvent](ctx, EVENT_STORAGE_OBJECT_UNPINNED, func(evt *StorageObjectPinnedEvent) error { + evt.SetPin(pin) + return nil + }) +}