func (m *mongoPubSub) Publish(ctx context.Context, _ types.RealmID, tenant string, event EventMessage) error {
// ...
_, err = collection.InsertOne(ctx, me)
if err != nil {
return types.NewHTTPError(http.StatusInternalServerError, err)
}
return nil // Explicitly return nil to avoid typed nil issues
}
func (m *mongoPubSub) Publish(ctx context.Context, _ types.RealmID, tenant string, event EventMessage) error {
// ...
_, err = collection.InsertOne(ctx, me)
if err != nil {
return types.NewHTTPError(http.StatusInternalServerError, err)
}
return nil // Explicitly return nil to avoid typed nil issues
}