adds import event

internal/models/global_api.go

@@ -5,6 +5,7 @@ const (
 	CatalogSharedEventType      = "catalog_shared"
 	CatalogUnsharedEventType    = "catalog_unshared"
 	ContextBoundEventType       = "context_bound"
+	CatalogImportedEventType    = "catalog_imported"
 )
 
 // Heartbeats are emitted to the global service periodically by running natster

natster/catalog.go

@@ -274,6 +274,9 @@ func ImportCatalog(ctx *fisk.ParseContext) error {
 			ShareOpts.Name, ShareOpts.AccountKey,
 		)
 	}
+	if !catFound && !mediaFound {
+		publishCatalogImported()
+	}
 	return nil
 }
 
@@ -423,6 +426,29 @@ func publishCatalogUnshared() error {
 	return nil
 }
 
+func publishCatalogImported() error {
+	ctx, _ := loadContext()
+	client, err := globalservice.NewClientWithCredsPath(ctx.CredsPath)
+	if err != nil {
+		slog.Error(
+			"Failed to connect to NGS",
+			slog.String("error", err.Error()),
+		)
+		return err
+	}
+	err = client.PublishEvent(models.CatalogImportedEventType, ShareOpts.Name, ShareOpts.AccountKey, nil)
+	if err != nil {
+		slog.Error(
+			"Failed to publish catalog unshared event",
+			slog.String("error", err.Error()),
+		)
+		return err
+	}
+	client.Drain()
+
+	return nil
+}
+
 func publishCatalogShared() error {
 	ctx, _ := loadContext()
 	client, err := globalservice.NewClientWithCredsPath(ctx.CredsPath)