// Code generated by ent, DO NOT EDIT. package models import ( "context" "errors" "fmt" "juwan-backend/app/notification/rpc/internal/models/notifications" "juwan-backend/app/notification/rpc/internal/models/predicate" "sync" "time" "entgo.io/ent" "entgo.io/ent/dialect/sql" ) const ( // Operation types. OpCreate = ent.OpCreate OpDelete = ent.OpDelete OpDeleteOne = ent.OpDeleteOne OpUpdate = ent.OpUpdate OpUpdateOne = ent.OpUpdateOne // Node types. TypeNotifications = "Notifications" ) // NotificationsMutation represents an operation that mutates the Notifications nodes in the graph. type NotificationsMutation struct { config op Op typ string id *int64 user_id *int64 adduser_id *int64 _type *string title *string content *string read *bool link *string created_at *time.Time updated_at *time.Time clearedFields map[string]struct{} done bool oldValue func(context.Context) (*Notifications, error) predicates []predicate.Notifications } var _ ent.Mutation = (*NotificationsMutation)(nil) // notificationsOption allows management of the mutation configuration using functional options. type notificationsOption func(*NotificationsMutation) // newNotificationsMutation creates new mutation for the Notifications entity. func newNotificationsMutation(c config, op Op, opts ...notificationsOption) *NotificationsMutation { m := &NotificationsMutation{ config: c, op: op, typ: TypeNotifications, clearedFields: make(map[string]struct{}), } for _, opt := range opts { opt(m) } return m } // withNotificationsID sets the ID field of the mutation. func withNotificationsID(id int64) notificationsOption { return func(m *NotificationsMutation) { var ( err error once sync.Once value *Notifications ) m.oldValue = func(ctx context.Context) (*Notifications, error) { once.Do(func() { if m.done { err = errors.New("querying old values post mutation is not allowed") } else { value, err = m.Client().Notifications.Get(ctx, id) } }) return value, err } m.id = &id } } // withNotifications sets the old Notifications of the mutation. func withNotifications(node *Notifications) notificationsOption { return func(m *NotificationsMutation) { m.oldValue = func(context.Context) (*Notifications, error) { return node, nil } m.id = &node.ID } } // Client returns a new `ent.Client` from the mutation. If the mutation was // executed in a transaction (ent.Tx), a transactional client is returned. func (m NotificationsMutation) Client() *Client { client := &Client{config: m.config} client.init() return client } // Tx returns an `ent.Tx` for mutations that were executed in transactions; // it returns an error otherwise. func (m NotificationsMutation) Tx() (*Tx, error) { if _, ok := m.driver.(*txDriver); !ok { return nil, errors.New("models: mutation is not running in a transaction") } tx := &Tx{config: m.config} tx.init() return tx, nil } // SetID sets the value of the id field. Note that this // operation is only accepted on creation of Notifications entities. func (m *NotificationsMutation) SetID(id int64) { m.id = &id } // ID returns the ID value in the mutation. Note that the ID is only available // if it was provided to the builder or after it was returned from the database. func (m *NotificationsMutation) ID() (id int64, exists bool) { if m.id == nil { return } return *m.id, true } // IDs queries the database and returns the entity ids that match the mutation's predicate. // That means, if the mutation is applied within a transaction with an isolation level such // as sql.LevelSerializable, the returned ids match the ids of the rows that will be updated // or updated by the mutation. func (m *NotificationsMutation) IDs(ctx context.Context) ([]int64, error) { switch { case m.op.Is(OpUpdateOne | OpDeleteOne): id, exists := m.ID() if exists { return []int64{id}, nil } fallthrough case m.op.Is(OpUpdate | OpDelete): return m.Client().Notifications.Query().Where(m.predicates...).IDs(ctx) default: return nil, fmt.Errorf("IDs is not allowed on %s operations", m.op) } } // SetUserID sets the "user_id" field. func (m *NotificationsMutation) SetUserID(i int64) { m.user_id = &i m.adduser_id = nil } // UserID returns the value of the "user_id" field in the mutation. func (m *NotificationsMutation) UserID() (r int64, exists bool) { v := m.user_id if v == nil { return } return *v, true } // OldUserID returns the old "user_id" field's value of the Notifications entity. // If the Notifications object wasn't provided to the builder, the object is fetched from the database. // An error is returned if the mutation operation is not UpdateOne, or the database query fails. func (m *NotificationsMutation) OldUserID(ctx context.Context) (v int64, err error) { if !m.op.Is(OpUpdateOne) { return v, errors.New("OldUserID is only allowed on UpdateOne operations") } if m.id == nil || m.oldValue == nil { return v, errors.New("OldUserID requires an ID field in the mutation") } oldValue, err := m.oldValue(ctx) if err != nil { return v, fmt.Errorf("querying old value for OldUserID: %w", err) } return oldValue.UserID, nil } // AddUserID adds i to the "user_id" field. func (m *NotificationsMutation) AddUserID(i int64) { if m.adduser_id != nil { *m.adduser_id += i } else { m.adduser_id = &i } } // AddedUserID returns the value that was added to the "user_id" field in this mutation. func (m *NotificationsMutation) AddedUserID() (r int64, exists bool) { v := m.adduser_id if v == nil { return } return *v, true } // ResetUserID resets all changes to the "user_id" field. func (m *NotificationsMutation) ResetUserID() { m.user_id = nil m.adduser_id = nil } // SetType sets the "type" field. func (m *NotificationsMutation) SetType(s string) { m._type = &s } // GetType returns the value of the "type" field in the mutation. func (m *NotificationsMutation) GetType() (r string, exists bool) { v := m._type if v == nil { return } return *v, true } // OldType returns the old "type" field's value of the Notifications entity. // If the Notifications object wasn't provided to the builder, the object is fetched from the database. // An error is returned if the mutation operation is not UpdateOne, or the database query fails. func (m *NotificationsMutation) OldType(ctx context.Context) (v string, err error) { if !m.op.Is(OpUpdateOne) { return v, errors.New("OldType is only allowed on UpdateOne operations") } if m.id == nil || m.oldValue == nil { return v, errors.New("OldType requires an ID field in the mutation") } oldValue, err := m.oldValue(ctx) if err != nil { return v, fmt.Errorf("querying old value for OldType: %w", err) } return oldValue.Type, nil } // ResetType resets all changes to the "type" field. func (m *NotificationsMutation) ResetType() { m._type = nil } // SetTitle sets the "title" field. func (m *NotificationsMutation) SetTitle(s string) { m.title = &s } // Title returns the value of the "title" field in the mutation. func (m *NotificationsMutation) Title() (r string, exists bool) { v := m.title if v == nil { return } return *v, true } // OldTitle returns the old "title" field's value of the Notifications entity. // If the Notifications object wasn't provided to the builder, the object is fetched from the database. // An error is returned if the mutation operation is not UpdateOne, or the database query fails. func (m *NotificationsMutation) OldTitle(ctx context.Context) (v string, err error) { if !m.op.Is(OpUpdateOne) { return v, errors.New("OldTitle is only allowed on UpdateOne operations") } if m.id == nil || m.oldValue == nil { return v, errors.New("OldTitle requires an ID field in the mutation") } oldValue, err := m.oldValue(ctx) if err != nil { return v, fmt.Errorf("querying old value for OldTitle: %w", err) } return oldValue.Title, nil } // ResetTitle resets all changes to the "title" field. func (m *NotificationsMutation) ResetTitle() { m.title = nil } // SetContent sets the "content" field. func (m *NotificationsMutation) SetContent(s string) { m.content = &s } // Content returns the value of the "content" field in the mutation. func (m *NotificationsMutation) Content() (r string, exists bool) { v := m.content if v == nil { return } return *v, true } // OldContent returns the old "content" field's value of the Notifications entity. // If the Notifications object wasn't provided to the builder, the object is fetched from the database. // An error is returned if the mutation operation is not UpdateOne, or the database query fails. func (m *NotificationsMutation) OldContent(ctx context.Context) (v string, err error) { if !m.op.Is(OpUpdateOne) { return v, errors.New("OldContent is only allowed on UpdateOne operations") } if m.id == nil || m.oldValue == nil { return v, errors.New("OldContent requires an ID field in the mutation") } oldValue, err := m.oldValue(ctx) if err != nil { return v, fmt.Errorf("querying old value for OldContent: %w", err) } return oldValue.Content, nil } // ResetContent resets all changes to the "content" field. func (m *NotificationsMutation) ResetContent() { m.content = nil } // SetRead sets the "read" field. func (m *NotificationsMutation) SetRead(b bool) { m.read = &b } // Read returns the value of the "read" field in the mutation. func (m *NotificationsMutation) Read() (r bool, exists bool) { v := m.read if v == nil { return } return *v, true } // OldRead returns the old "read" field's value of the Notifications entity. // If the Notifications object wasn't provided to the builder, the object is fetched from the database. // An error is returned if the mutation operation is not UpdateOne, or the database query fails. func (m *NotificationsMutation) OldRead(ctx context.Context) (v bool, err error) { if !m.op.Is(OpUpdateOne) { return v, errors.New("OldRead is only allowed on UpdateOne operations") } if m.id == nil || m.oldValue == nil { return v, errors.New("OldRead requires an ID field in the mutation") } oldValue, err := m.oldValue(ctx) if err != nil { return v, fmt.Errorf("querying old value for OldRead: %w", err) } return oldValue.Read, nil } // ResetRead resets all changes to the "read" field. func (m *NotificationsMutation) ResetRead() { m.read = nil } // SetLink sets the "link" field. func (m *NotificationsMutation) SetLink(s string) { m.link = &s } // Link returns the value of the "link" field in the mutation. func (m *NotificationsMutation) Link() (r string, exists bool) { v := m.link if v == nil { return } return *v, true } // OldLink returns the old "link" field's value of the Notifications entity. // If the Notifications object wasn't provided to the builder, the object is fetched from the database. // An error is returned if the mutation operation is not UpdateOne, or the database query fails. func (m *NotificationsMutation) OldLink(ctx context.Context) (v *string, err error) { if !m.op.Is(OpUpdateOne) { return v, errors.New("OldLink is only allowed on UpdateOne operations") } if m.id == nil || m.oldValue == nil { return v, errors.New("OldLink requires an ID field in the mutation") } oldValue, err := m.oldValue(ctx) if err != nil { return v, fmt.Errorf("querying old value for OldLink: %w", err) } return oldValue.Link, nil } // ClearLink clears the value of the "link" field. func (m *NotificationsMutation) ClearLink() { m.link = nil m.clearedFields[notifications.FieldLink] = struct{}{} } // LinkCleared returns if the "link" field was cleared in this mutation. func (m *NotificationsMutation) LinkCleared() bool { _, ok := m.clearedFields[notifications.FieldLink] return ok } // ResetLink resets all changes to the "link" field. func (m *NotificationsMutation) ResetLink() { m.link = nil delete(m.clearedFields, notifications.FieldLink) } // SetCreatedAt sets the "created_at" field. func (m *NotificationsMutation) SetCreatedAt(t time.Time) { m.created_at = &t } // CreatedAt returns the value of the "created_at" field in the mutation. func (m *NotificationsMutation) CreatedAt() (r time.Time, exists bool) { v := m.created_at if v == nil { return } return *v, true } // OldCreatedAt returns the old "created_at" field's value of the Notifications entity. // If the Notifications object wasn't provided to the builder, the object is fetched from the database. // An error is returned if the mutation operation is not UpdateOne, or the database query fails. func (m *NotificationsMutation) OldCreatedAt(ctx context.Context) (v time.Time, err error) { if !m.op.Is(OpUpdateOne) { return v, errors.New("OldCreatedAt is only allowed on UpdateOne operations") } if m.id == nil || m.oldValue == nil { return v, errors.New("OldCreatedAt requires an ID field in the mutation") } oldValue, err := m.oldValue(ctx) if err != nil { return v, fmt.Errorf("querying old value for OldCreatedAt: %w", err) } return oldValue.CreatedAt, nil } // ResetCreatedAt resets all changes to the "created_at" field. func (m *NotificationsMutation) ResetCreatedAt() { m.created_at = nil } // SetUpdatedAt sets the "updated_at" field. func (m *NotificationsMutation) SetUpdatedAt(t time.Time) { m.updated_at = &t } // UpdatedAt returns the value of the "updated_at" field in the mutation. func (m *NotificationsMutation) UpdatedAt() (r time.Time, exists bool) { v := m.updated_at if v == nil { return } return *v, true } // OldUpdatedAt returns the old "updated_at" field's value of the Notifications entity. // If the Notifications object wasn't provided to the builder, the object is fetched from the database. // An error is returned if the mutation operation is not UpdateOne, or the database query fails. func (m *NotificationsMutation) OldUpdatedAt(ctx context.Context) (v time.Time, err error) { if !m.op.Is(OpUpdateOne) { return v, errors.New("OldUpdatedAt is only allowed on UpdateOne operations") } if m.id == nil || m.oldValue == nil { return v, errors.New("OldUpdatedAt requires an ID field in the mutation") } oldValue, err := m.oldValue(ctx) if err != nil { return v, fmt.Errorf("querying old value for OldUpdatedAt: %w", err) } return oldValue.UpdatedAt, nil } // ResetUpdatedAt resets all changes to the "updated_at" field. func (m *NotificationsMutation) ResetUpdatedAt() { m.updated_at = nil } // Where appends a list predicates to the NotificationsMutation builder. func (m *NotificationsMutation) Where(ps ...predicate.Notifications) { m.predicates = append(m.predicates, ps...) } // WhereP appends storage-level predicates to the NotificationsMutation builder. Using this method, // users can use type-assertion to append predicates that do not depend on any generated package. func (m *NotificationsMutation) WhereP(ps ...func(*sql.Selector)) { p := make([]predicate.Notifications, len(ps)) for i := range ps { p[i] = ps[i] } m.Where(p...) } // Op returns the operation name. func (m *NotificationsMutation) Op() Op { return m.op } // SetOp allows setting the mutation operation. func (m *NotificationsMutation) SetOp(op Op) { m.op = op } // Type returns the node type of this mutation (Notifications). func (m *NotificationsMutation) Type() string { return m.typ } // Fields returns all fields that were changed during this mutation. Note that in // order to get all numeric fields that were incremented/decremented, call // AddedFields(). func (m *NotificationsMutation) Fields() []string { fields := make([]string, 0, 8) if m.user_id != nil { fields = append(fields, notifications.FieldUserID) } if m._type != nil { fields = append(fields, notifications.FieldType) } if m.title != nil { fields = append(fields, notifications.FieldTitle) } if m.content != nil { fields = append(fields, notifications.FieldContent) } if m.read != nil { fields = append(fields, notifications.FieldRead) } if m.link != nil { fields = append(fields, notifications.FieldLink) } if m.created_at != nil { fields = append(fields, notifications.FieldCreatedAt) } if m.updated_at != nil { fields = append(fields, notifications.FieldUpdatedAt) } return fields } // Field returns the value of a field with the given name. The second boolean // return value indicates that this field was not set, or was not defined in the // schema. func (m *NotificationsMutation) Field(name string) (ent.Value, bool) { switch name { case notifications.FieldUserID: return m.UserID() case notifications.FieldType: return m.GetType() case notifications.FieldTitle: return m.Title() case notifications.FieldContent: return m.Content() case notifications.FieldRead: return m.Read() case notifications.FieldLink: return m.Link() case notifications.FieldCreatedAt: return m.CreatedAt() case notifications.FieldUpdatedAt: return m.UpdatedAt() } return nil, false } // OldField returns the old value of the field from the database. An error is // returned if the mutation operation is not UpdateOne, or the query to the // database failed. func (m *NotificationsMutation) OldField(ctx context.Context, name string) (ent.Value, error) { switch name { case notifications.FieldUserID: return m.OldUserID(ctx) case notifications.FieldType: return m.OldType(ctx) case notifications.FieldTitle: return m.OldTitle(ctx) case notifications.FieldContent: return m.OldContent(ctx) case notifications.FieldRead: return m.OldRead(ctx) case notifications.FieldLink: return m.OldLink(ctx) case notifications.FieldCreatedAt: return m.OldCreatedAt(ctx) case notifications.FieldUpdatedAt: return m.OldUpdatedAt(ctx) } return nil, fmt.Errorf("unknown Notifications field %s", name) } // SetField sets the value of a field with the given name. It returns an error if // the field is not defined in the schema, or if the type mismatched the field // type. func (m *NotificationsMutation) SetField(name string, value ent.Value) error { switch name { case notifications.FieldUserID: v, ok := value.(int64) if !ok { return fmt.Errorf("unexpected type %T for field %s", value, name) } m.SetUserID(v) return nil case notifications.FieldType: v, ok := value.(string) if !ok { return fmt.Errorf("unexpected type %T for field %s", value, name) } m.SetType(v) return nil case notifications.FieldTitle: v, ok := value.(string) if !ok { return fmt.Errorf("unexpected type %T for field %s", value, name) } m.SetTitle(v) return nil case notifications.FieldContent: v, ok := value.(string) if !ok { return fmt.Errorf("unexpected type %T for field %s", value, name) } m.SetContent(v) return nil case notifications.FieldRead: v, ok := value.(bool) if !ok { return fmt.Errorf("unexpected type %T for field %s", value, name) } m.SetRead(v) return nil case notifications.FieldLink: v, ok := value.(string) if !ok { return fmt.Errorf("unexpected type %T for field %s", value, name) } m.SetLink(v) return nil case notifications.FieldCreatedAt: v, ok := value.(time.Time) if !ok { return fmt.Errorf("unexpected type %T for field %s", value, name) } m.SetCreatedAt(v) return nil case notifications.FieldUpdatedAt: v, ok := value.(time.Time) if !ok { return fmt.Errorf("unexpected type %T for field %s", value, name) } m.SetUpdatedAt(v) return nil } return fmt.Errorf("unknown Notifications field %s", name) } // AddedFields returns all numeric fields that were incremented/decremented during // this mutation. func (m *NotificationsMutation) AddedFields() []string { var fields []string if m.adduser_id != nil { fields = append(fields, notifications.FieldUserID) } return fields } // AddedField returns the numeric value that was incremented/decremented on a field // with the given name. The second boolean return value indicates that this field // was not set, or was not defined in the schema. func (m *NotificationsMutation) AddedField(name string) (ent.Value, bool) { switch name { case notifications.FieldUserID: return m.AddedUserID() } return nil, false } // AddField adds the value to the field with the given name. It returns an error if // the field is not defined in the schema, or if the type mismatched the field // type. func (m *NotificationsMutation) AddField(name string, value ent.Value) error { switch name { case notifications.FieldUserID: v, ok := value.(int64) if !ok { return fmt.Errorf("unexpected type %T for field %s", value, name) } m.AddUserID(v) return nil } return fmt.Errorf("unknown Notifications numeric field %s", name) } // ClearedFields returns all nullable fields that were cleared during this // mutation. func (m *NotificationsMutation) ClearedFields() []string { var fields []string if m.FieldCleared(notifications.FieldLink) { fields = append(fields, notifications.FieldLink) } return fields } // FieldCleared returns a boolean indicating if a field with the given name was // cleared in this mutation. func (m *NotificationsMutation) FieldCleared(name string) bool { _, ok := m.clearedFields[name] return ok } // ClearField clears the value of the field with the given name. It returns an // error if the field is not defined in the schema. func (m *NotificationsMutation) ClearField(name string) error { switch name { case notifications.FieldLink: m.ClearLink() return nil } return fmt.Errorf("unknown Notifications nullable field %s", name) } // ResetField resets all changes in the mutation for the field with the given name. // It returns an error if the field is not defined in the schema. func (m *NotificationsMutation) ResetField(name string) error { switch name { case notifications.FieldUserID: m.ResetUserID() return nil case notifications.FieldType: m.ResetType() return nil case notifications.FieldTitle: m.ResetTitle() return nil case notifications.FieldContent: m.ResetContent() return nil case notifications.FieldRead: m.ResetRead() return nil case notifications.FieldLink: m.ResetLink() return nil case notifications.FieldCreatedAt: m.ResetCreatedAt() return nil case notifications.FieldUpdatedAt: m.ResetUpdatedAt() return nil } return fmt.Errorf("unknown Notifications field %s", name) } // AddedEdges returns all edge names that were set/added in this mutation. func (m *NotificationsMutation) AddedEdges() []string { edges := make([]string, 0, 0) return edges } // AddedIDs returns all IDs (to other nodes) that were added for the given edge // name in this mutation. func (m *NotificationsMutation) AddedIDs(name string) []ent.Value { return nil } // RemovedEdges returns all edge names that were removed in this mutation. func (m *NotificationsMutation) RemovedEdges() []string { edges := make([]string, 0, 0) return edges } // RemovedIDs returns all IDs (to other nodes) that were removed for the edge with // the given name in this mutation. func (m *NotificationsMutation) RemovedIDs(name string) []ent.Value { return nil } // ClearedEdges returns all edge names that were cleared in this mutation. func (m *NotificationsMutation) ClearedEdges() []string { edges := make([]string, 0, 0) return edges } // EdgeCleared returns a boolean which indicates if the edge with the given name // was cleared in this mutation. func (m *NotificationsMutation) EdgeCleared(name string) bool { return false } // ClearEdge clears the value of the edge with the given name. It returns an error // if that edge is not defined in the schema. func (m *NotificationsMutation) ClearEdge(name string) error { return fmt.Errorf("unknown Notifications unique edge %s", name) } // ResetEdge resets all changes to the edge with the given name in this mutation. // It returns an error if the edge is not defined in the schema. func (m *NotificationsMutation) ResetEdge(name string) error { return fmt.Errorf("unknown Notifications edge %s", name) }