Method Create

inventory/fs_event.go:43–56

(ctx context.Context, uid int, subscriberId uuid.UUID, events ...string)

}

func (c *fsEventClient) Create(ctx context.Context, uid int, subscriberId uuid.UUID, events ...string) error {
	stms := lo.Map(events, func(event string, index int) *ent.FsEventCreate {
		res := c.client.FsEvent.
			Create().
			SetUserFsevent(uid).
			SetEvent(event).
			SetSubscriber(subscriberId).SetEvent(event)

		return res
	})

	_, err := c.client.FsEvent.CreateBulk(stms...).Save(ctx)
	return err
}

func (c *fsEventClient) DeleteBySubscriber(ctx context.Context, subscriberId uuid.UUID) error {
	_, err := c.client.FsEvent.Delete().Where(fsevent.Subscriber(subscriberId)).Exec(schema.SkipSoftDelete(ctx))