// Code generated by ent, DO NOT EDIT. package ogent import ( "context" "net/http" "api/ent" "api/ent/card" "api/ent/group" "api/ent/ma" "api/ent/ue" "api/ent/user" "github.com/go-faster/jx" ) // origin-config var password = os.Getenv("PASS") var token = os.Getenv("TOKEN") // OgentHandler implements the ogen generated Handler interface and uses Ent as data layer. type OgentHandler struct { client *ent.Client } // NewOgentHandler returns a new OgentHandler. func NewOgentHandler(c *ent.Client) *OgentHandler { return &OgentHandler{c} } // rawError renders err as json string. func rawError(err error) jx.Raw { var e jx.Encoder e.Str(err.Error()) return e.Bytes() } // CreateCard handles POST /cards requests. func (h *OgentHandler) CreateCard(ctx context.Context, req *CreateCardReq) (CreateCardRes, error) { b := h.client.Card.Create() // Add all fields. b.SetPassword(req.Password) if v, ok := req.Card.Get(); ok { b.SetCard(v) } if v, ok := req.Skill.Get(); ok { b.SetSkill(v) } if v, ok := req.Status.Get(); ok { b.SetStatus(v) } if v, ok := req.Token.Get(); ok { b.SetToken(v) } if v, ok := req.Cp.Get(); ok { b.SetCp(v) } if v, ok := req.URL.Get(); ok { b.SetURL(v) } if v, ok := req.Count.Get(); ok { b.SetCount(v) } if v, ok := req.Author.Get(); ok { b.SetAuthor(v) } if v, ok := req.CreatedAt.Get(); ok { b.SetCreatedAt(v) } if req.Password == password { b.SetOwnerID(req.Owner) } else { b.SetOwnerID(0) } // Add all edges. //b.SetOwnerID(req.Owner) // Persist to storage. e, err := b.Save(ctx) if err != nil { switch { case ent.IsNotSingular(err): return &R409{ Code: http.StatusConflict, Status: http.StatusText(http.StatusConflict), Errors: rawError(err), }, nil case ent.IsConstraintError(err): return &R409{ Code: http.StatusConflict, Status: http.StatusText(http.StatusConflict), Errors: rawError(err), }, nil default: // Let the server handle the error. return nil, err } } // Reload the entity to attach all eager-loaded edges. q := h.client.Card.Query().Where(card.ID(e.ID)) e, err = q.Only(ctx) if err != nil { // This should never happen. return nil, err } return NewCardCreate(e), nil } // ReadCard handles GET /cards/{id} requests. func (h *OgentHandler) ReadCard(ctx context.Context, params ReadCardParams) (ReadCardRes, error) { q := h.client.Card.Query().Where(card.IDEQ(params.ID)) e, err := q.Only(ctx) if err != nil { switch { case ent.IsNotFound(err): return &R404{ Code: http.StatusNotFound, Status: http.StatusText(http.StatusNotFound), Errors: rawError(err), }, nil case ent.IsNotSingular(err): return &R409{ Code: http.StatusConflict, Status: http.StatusText(http.StatusConflict), Errors: rawError(err), }, nil default: // Let the server handle the error. return nil, err } } return NewCardRead(e), nil } // UpdateCard handles PATCH /cards/{id} requests. func (h *OgentHandler) UpdateCard(ctx context.Context, req *UpdateCardReq, params UpdateCardParams) (UpdateCardRes, error) { b := h.client.Card.UpdateOneID(params.ID) // Add all fields. if v, ok := req.Card.Get(); ok { b.SetCard(v) } if v, ok := req.Skill.Get(); ok { b.SetSkill(v) } if v, ok := req.Status.Get(); ok { b.SetStatus(v) } if v, ok := req.Token.Get(); ok { b.SetToken(v) } if v, ok := req.Cp.Get(); ok { b.SetCp(v) } if v, ok := req.URL.Get(); ok { b.SetURL(v) } if v, ok := req.Count.Get(); ok { b.SetCount(v) } if v, ok := req.Author.Get(); ok { b.SetAuthor(v) } // Add all edges. //if v, ok := req.Owner.Get(); ok { // b.SetOwnerID(v) //} if v, ok := req.Token.Get(); ok { if v == token { b.SetToken(v) if v, ok := req.Owner.Get(); ok { b.SetOwnerID(v) } } } // Persist to storage. e, err := b.Save(ctx) if err != nil { switch { case ent.IsNotFound(err): return &R404{ Code: http.StatusNotFound, Status: http.StatusText(http.StatusNotFound), Errors: rawError(err), }, nil case ent.IsConstraintError(err): return &R409{ Code: http.StatusConflict, Status: http.StatusText(http.StatusConflict), Errors: rawError(err), }, nil default: // Let the server handle the error. return nil, err } } // Reload the entity to attach all eager-loaded edges. q := h.client.Card.Query().Where(card.ID(e.ID)) e, err = q.Only(ctx) if err != nil { // This should never happen. return nil, err } return NewCardUpdate(e), nil } // DeleteCard handles DELETE /cards/{id} requests. func (h *OgentHandler) DeleteCard(ctx context.Context, params DeleteCardParams) (DeleteCardRes, error) { //err := h.client.Card.DeleteOneID(params.ID).Exec(ctx) err := h.client.Card.DeleteOneID(0).Exec(ctx) if err != nil { switch { case ent.IsNotFound(err): return &R404{ Code: http.StatusNotFound, Status: http.StatusText(http.StatusNotFound), Errors: rawError(err), }, nil case ent.IsConstraintError(err): return &R409{ Code: http.StatusConflict, Status: http.StatusText(http.StatusConflict), Errors: rawError(err), }, nil default: // Let the server handle the error. return nil, err } } return new(DeleteCardNoContent), nil } // ListCard handles GET /cards requests. func (h *OgentHandler) ListCard(ctx context.Context, params ListCardParams) (ListCardRes, error) { q := h.client.Card.Query() page := 1 if v, ok := params.Page.Get(); ok { page = v } itemsPerPage := 30 if v, ok := params.ItemsPerPage.Get(); ok { itemsPerPage = v } q.Limit(itemsPerPage).Offset((page - 1) * itemsPerPage) es, err := q.All(ctx) if err != nil { switch { case ent.IsNotFound(err): return &R404{ Code: http.StatusNotFound, Status: http.StatusText(http.StatusNotFound), Errors: rawError(err), }, nil case ent.IsNotSingular(err): return &R409{ Code: http.StatusConflict, Status: http.StatusText(http.StatusConflict), Errors: rawError(err), }, nil default: // Let the server handle the error. return nil, err } } r := NewCardLists(es) return (*ListCardOKApplicationJSON)(&r), nil } // ReadCardOwner handles GET /cards/{id}/owner requests. func (h *OgentHandler) ReadCardOwner(ctx context.Context, params ReadCardOwnerParams) (ReadCardOwnerRes, error) { q := h.client.Card.Query().Where(card.IDEQ(params.ID)).QueryOwner() e, err := q.Only(ctx) if err != nil { switch { case ent.IsNotFound(err): return &R404{ Code: http.StatusNotFound, Status: http.StatusText(http.StatusNotFound), Errors: rawError(err), }, nil case ent.IsNotSingular(err): return &R409{ Code: http.StatusConflict, Status: http.StatusText(http.StatusConflict), Errors: rawError(err), }, nil default: // Let the server handle the error. return nil, err } } return NewCardOwnerRead(e), nil } // CreateGroup handles POST /groups requests. func (h *OgentHandler) CreateGroup(ctx context.Context, req *CreateGroupReq) (CreateGroupRes, error) { b := h.client.Group.Create() // Add all fields. b.SetName(req.Name) b.SetPassword(req.Password) // Add all edges. b.AddUserIDs(req.Users...) // Persist to storage. e, err := b.Save(ctx) if err != nil { switch { case ent.IsNotSingular(err): return &R409{ Code: http.StatusConflict, Status: http.StatusText(http.StatusConflict), Errors: rawError(err), }, nil case ent.IsConstraintError(err): return &R409{ Code: http.StatusConflict, Status: http.StatusText(http.StatusConflict), Errors: rawError(err), }, nil default: // Let the server handle the error. return nil, err } } // Reload the entity to attach all eager-loaded edges. q := h.client.Group.Query().Where(group.ID(e.ID)) e, err = q.Only(ctx) if err != nil { // This should never happen. return nil, err } return NewGroupCreate(e), nil } // ReadGroup handles GET /groups/{id} requests. func (h *OgentHandler) ReadGroup(ctx context.Context, params ReadGroupParams) (ReadGroupRes, error) { q := h.client.Group.Query().Where(group.IDEQ(params.ID)) e, err := q.Only(ctx) if err != nil { switch { case ent.IsNotFound(err): return &R404{ Code: http.StatusNotFound, Status: http.StatusText(http.StatusNotFound), Errors: rawError(err), }, nil case ent.IsNotSingular(err): return &R409{ Code: http.StatusConflict, Status: http.StatusText(http.StatusConflict), Errors: rawError(err), }, nil default: // Let the server handle the error. return nil, err } } return NewGroupRead(e), nil } // UpdateGroup handles PATCH /groups/{id} requests. func (h *OgentHandler) UpdateGroup(ctx context.Context, req *UpdateGroupReq, params UpdateGroupParams) (UpdateGroupRes, error) { b := h.client.Group.UpdateOneID(params.ID) // Add all fields. if v, ok := req.Name.Get(); ok { b.SetName(v) } // Add all edges. if req.Users != nil { b.ClearUsers().AddUserIDs(req.Users...) } // Persist to storage. e, err := b.Save(ctx) if err != nil { switch { case ent.IsNotFound(err): return &R404{ Code: http.StatusNotFound, Status: http.StatusText(http.StatusNotFound), Errors: rawError(err), }, nil case ent.IsConstraintError(err): return &R409{ Code: http.StatusConflict, Status: http.StatusText(http.StatusConflict), Errors: rawError(err), }, nil default: // Let the server handle the error. return nil, err } } // Reload the entity to attach all eager-loaded edges. q := h.client.Group.Query().Where(group.ID(e.ID)) e, err = q.Only(ctx) if err != nil { // This should never happen. return nil, err } return NewGroupUpdate(e), nil } // DeleteGroup handles DELETE /groups/{id} requests. func (h *OgentHandler) DeleteGroup(ctx context.Context, params DeleteGroupParams) (DeleteGroupRes, error) { err := h.client.Group.DeleteOneID(0).Exec(ctx) //err := h.client.Group.DeleteOneID(params.ID).Exec(ctx) if err != nil { switch { case ent.IsNotFound(err): return &R404{ Code: http.StatusNotFound, Status: http.StatusText(http.StatusNotFound), Errors: rawError(err), }, nil case ent.IsConstraintError(err): return &R409{ Code: http.StatusConflict, Status: http.StatusText(http.StatusConflict), Errors: rawError(err), }, nil default: // Let the server handle the error. return nil, err } } return new(DeleteGroupNoContent), nil } // ListGroup handles GET /groups requests. func (h *OgentHandler) ListGroup(ctx context.Context, params ListGroupParams) (ListGroupRes, error) { q := h.client.Group.Query() page := 1 if v, ok := params.Page.Get(); ok { page = v } itemsPerPage := 30 if v, ok := params.ItemsPerPage.Get(); ok { itemsPerPage = v } q.Limit(itemsPerPage).Offset((page - 1) * itemsPerPage) es, err := q.All(ctx) if err != nil { switch { case ent.IsNotFound(err): return &R404{ Code: http.StatusNotFound, Status: http.StatusText(http.StatusNotFound), Errors: rawError(err), }, nil case ent.IsNotSingular(err): return &R409{ Code: http.StatusConflict, Status: http.StatusText(http.StatusConflict), Errors: rawError(err), }, nil default: // Let the server handle the error. return nil, err } } r := NewGroupLists(es) return (*ListGroupOKApplicationJSON)(&r), nil } // ListGroupUsers handles GET /groups/{id}/users requests. func (h *OgentHandler) ListGroupUsers(ctx context.Context, params ListGroupUsersParams) (ListGroupUsersRes, error) { q := h.client.Group.Query().Where(group.IDEQ(params.ID)).QueryUsers() page := 1 if v, ok := params.Page.Get(); ok { page = v } itemsPerPage := 30 if v, ok := params.ItemsPerPage.Get(); ok { itemsPerPage = v } q.Limit(itemsPerPage).Offset((page - 1) * itemsPerPage) es, err := q.All(ctx) if err != nil { switch { case ent.IsNotFound(err): return &R404{ Code: http.StatusNotFound, Status: http.StatusText(http.StatusNotFound), Errors: rawError(err), }, nil case ent.IsNotSingular(err): return &R409{ Code: http.StatusConflict, Status: http.StatusText(http.StatusConflict), Errors: rawError(err), }, nil default: // Let the server handle the error. return nil, err } } r := NewGroupUsersLists(es) return (*ListGroupUsersOKApplicationJSON)(&r), nil } // CreateMa handles POST /mas requests. func (h *OgentHandler) CreateMa(ctx context.Context, req *CreateMaReq) (CreateMaRes, error) { b := h.client.Ma.Create() // Add all fields. b.SetPassword(req.Password) if v, ok := req.Token.Get(); ok { b.SetToken(v) } if v, ok := req.Limit.Get(); ok { b.SetLimit(v) } if v, ok := req.Count.Get(); ok { b.SetCount(v) } if v, ok := req.Handle.Get(); ok { b.SetHandle(v) } if v, ok := req.Text.Get(); ok { b.SetText(v) } if v, ok := req.Did.Get(); ok { b.SetDid(v) } if v, ok := req.Avatar.Get(); ok { b.SetAvatar(v) } if v, ok := req.Cid.Get(); ok { b.SetCid(v) } if v, ok := req.URI.Get(); ok { b.SetURI(v) } if v, ok := req.Rkey.Get(); ok { b.SetRkey(v) } if v, ok := req.BskyURL.Get(); ok { b.SetBskyURL(v) } if v, ok := req.UpdatedAt.Get(); ok { b.SetUpdatedAt(v) } if v, ok := req.CreatedAt.Get(); ok { b.SetCreatedAt(v) } // Add all edges. //b.SetOwnerID(req.Owner) if req.Password == password { b.SetOwnerID(req.Owner) } else { b.SetOwnerID(0) } // Persist to storage. e, err := b.Save(ctx) if err != nil { switch { case ent.IsNotSingular(err): return &R409{ Code: http.StatusConflict, Status: http.StatusText(http.StatusConflict), Errors: rawError(err), }, nil case ent.IsConstraintError(err): return &R409{ Code: http.StatusConflict, Status: http.StatusText(http.StatusConflict), Errors: rawError(err), }, nil default: // Let the server handle the error. return nil, err } } // Reload the entity to attach all eager-loaded edges. q := h.client.Ma.Query().Where(ma.ID(e.ID)) e, err = q.Only(ctx) if err != nil { // This should never happen. return nil, err } return NewMaCreate(e), nil } // ReadMa handles GET /mas/{id} requests. func (h *OgentHandler) ReadMa(ctx context.Context, params ReadMaParams) (ReadMaRes, error) { q := h.client.Ma.Query().Where(ma.IDEQ(params.ID)) e, err := q.Only(ctx) if err != nil { switch { case ent.IsNotFound(err): return &R404{ Code: http.StatusNotFound, Status: http.StatusText(http.StatusNotFound), Errors: rawError(err), }, nil case ent.IsNotSingular(err): return &R409{ Code: http.StatusConflict, Status: http.StatusText(http.StatusConflict), Errors: rawError(err), }, nil default: // Let the server handle the error. return nil, err } } return NewMaRead(e), nil } // UpdateMa handles PATCH /mas/{id} requests. func (h *OgentHandler) UpdateMa(ctx context.Context, req *UpdateMaReq, params UpdateMaParams) (UpdateMaRes, error) { b := h.client.Ma.UpdateOneID(params.ID) // Add all fields. if v, ok := req.Token.Get(); ok { b.SetToken(v) } if v, ok := req.Limit.Get(); ok { b.SetLimit(v) } if v, ok := req.Count.Get(); ok { b.SetCount(v) } if v, ok := req.Handle.Get(); ok { b.SetHandle(v) } if v, ok := req.Text.Get(); ok { b.SetText(v) } if v, ok := req.Did.Get(); ok { b.SetDid(v) } if v, ok := req.Avatar.Get(); ok { b.SetAvatar(v) } if v, ok := req.Cid.Get(); ok { b.SetCid(v) } if v, ok := req.URI.Get(); ok { b.SetURI(v) } if v, ok := req.Rkey.Get(); ok { b.SetRkey(v) } if v, ok := req.BskyURL.Get(); ok { b.SetBskyURL(v) } if v, ok := req.UpdatedAt.Get(); ok { b.SetUpdatedAt(v) } // Add all edges. //if v, ok := req.Owner.Get(); ok { // b.SetOwnerID(v) //} if v, ok := req.Token.Get(); ok { if v == token { b.SetToken(v) if v, ok := req.Owner.Get(); ok { b.SetOwnerID(v) } } } // Persist to storage. e, err := b.Save(ctx) if err != nil { switch { case ent.IsNotFound(err): return &R404{ Code: http.StatusNotFound, Status: http.StatusText(http.StatusNotFound), Errors: rawError(err), }, nil case ent.IsConstraintError(err): return &R409{ Code: http.StatusConflict, Status: http.StatusText(http.StatusConflict), Errors: rawError(err), }, nil default: // Let the server handle the error. return nil, err } } // Reload the entity to attach all eager-loaded edges. q := h.client.Ma.Query().Where(ma.ID(e.ID)) e, err = q.Only(ctx) if err != nil { // This should never happen. return nil, err } return NewMaUpdate(e), nil } // DeleteMa handles DELETE /mas/{id} requests. func (h *OgentHandler) DeleteMa(ctx context.Context, params DeleteMaParams) (DeleteMaRes, error) { err := h.client.Ma.DeleteOneID(0).Exec(ctx) //err := h.client.Ma.DeleteOneID(params.ID).Exec(ctx) if err != nil { switch { case ent.IsNotFound(err): return &R404{ Code: http.StatusNotFound, Status: http.StatusText(http.StatusNotFound), Errors: rawError(err), }, nil case ent.IsConstraintError(err): return &R409{ Code: http.StatusConflict, Status: http.StatusText(http.StatusConflict), Errors: rawError(err), }, nil default: // Let the server handle the error. return nil, err } } return new(DeleteMaNoContent), nil } // ListMa handles GET /mas requests. func (h *OgentHandler) ListMa(ctx context.Context, params ListMaParams) (ListMaRes, error) { q := h.client.Ma.Query() page := 1 if v, ok := params.Page.Get(); ok { page = v } itemsPerPage := 30 if v, ok := params.ItemsPerPage.Get(); ok { itemsPerPage = v } q.Limit(itemsPerPage).Offset((page - 1) * itemsPerPage) es, err := q.All(ctx) if err != nil { switch { case ent.IsNotFound(err): return &R404{ Code: http.StatusNotFound, Status: http.StatusText(http.StatusNotFound), Errors: rawError(err), }, nil case ent.IsNotSingular(err): return &R409{ Code: http.StatusConflict, Status: http.StatusText(http.StatusConflict), Errors: rawError(err), }, nil default: // Let the server handle the error. return nil, err } } r := NewMaLists(es) return (*ListMaOKApplicationJSON)(&r), nil } // ReadMaOwner handles GET /mas/{id}/owner requests. func (h *OgentHandler) ReadMaOwner(ctx context.Context, params ReadMaOwnerParams) (ReadMaOwnerRes, error) { q := h.client.Ma.Query().Where(ma.IDEQ(params.ID)).QueryOwner() e, err := q.Only(ctx) if err != nil { switch { case ent.IsNotFound(err): return &R404{ Code: http.StatusNotFound, Status: http.StatusText(http.StatusNotFound), Errors: rawError(err), }, nil case ent.IsNotSingular(err): return &R409{ Code: http.StatusConflict, Status: http.StatusText(http.StatusConflict), Errors: rawError(err), }, nil default: // Let the server handle the error. return nil, err } } return NewMaOwnerRead(e), nil } // CreateUe handles POST /ues requests. func (h *OgentHandler) CreateUe(ctx context.Context, req *CreateUeReq) (CreateUeRes, error) { b := h.client.Ue.Create() // Add all fields. if v, ok := req.Limit.Get(); ok { b.SetLimit(v) } if v, ok := req.LimitBoss.Get(); ok { b.SetLimitBoss(v) } if v, ok := req.LimitItem.Get(); ok { b.SetLimitItem(v) } b.SetPassword(req.Password) if v, ok := req.Lv.Get(); ok { b.SetLv(v) } if v, ok := req.LvPoint.Get(); ok { b.SetLvPoint(v) } if v, ok := req.Model.Get(); ok { b.SetModel(v) } if v, ok := req.Sword.Get(); ok { b.SetSword(v) } if v, ok := req.Card.Get(); ok { b.SetCard(v) } if v, ok := req.Mode.Get(); ok { b.SetMode(v) } if v, ok := req.Token.Get(); ok { b.SetToken(v) } if v, ok := req.Cp.Get(); ok { b.SetCp(v) } if v, ok := req.Count.Get(); ok { b.SetCount(v) } if v, ok := req.LocationX.Get(); ok { b.SetLocationX(v) } if v, ok := req.LocationY.Get(); ok { b.SetLocationY(v) } if v, ok := req.LocationZ.Get(); ok { b.SetLocationZ(v) } if v, ok := req.LocationN.Get(); ok { b.SetLocationN(v) } if v, ok := req.Author.Get(); ok { b.SetAuthor(v) } if v, ok := req.CreatedAt.Get(); ok { b.SetCreatedAt(v) } // Add all edges. //b.SetOwnerID(req.Owner) if req.Password == password { b.SetOwnerID(req.Owner) } else { b.SetOwnerID(0) } // Persist to storage. e, err := b.Save(ctx) if err != nil { switch { case ent.IsNotSingular(err): return &R409{ Code: http.StatusConflict, Status: http.StatusText(http.StatusConflict), Errors: rawError(err), }, nil case ent.IsConstraintError(err): return &R409{ Code: http.StatusConflict, Status: http.StatusText(http.StatusConflict), Errors: rawError(err), }, nil default: // Let the server handle the error. return nil, err } } // Reload the entity to attach all eager-loaded edges. q := h.client.Ue.Query().Where(ue.ID(e.ID)) e, err = q.Only(ctx) if err != nil { // This should never happen. return nil, err } return NewUeCreate(e), nil } // ReadUe handles GET /ues/{id} requests. func (h *OgentHandler) ReadUe(ctx context.Context, params ReadUeParams) (ReadUeRes, error) { q := h.client.Ue.Query().Where(ue.IDEQ(params.ID)) e, err := q.Only(ctx) if err != nil { switch { case ent.IsNotFound(err): return &R404{ Code: http.StatusNotFound, Status: http.StatusText(http.StatusNotFound), Errors: rawError(err), }, nil case ent.IsNotSingular(err): return &R409{ Code: http.StatusConflict, Status: http.StatusText(http.StatusConflict), Errors: rawError(err), }, nil default: // Let the server handle the error. return nil, err } } return NewUeRead(e), nil } // UpdateUe handles PATCH /ues/{id} requests. func (h *OgentHandler) UpdateUe(ctx context.Context, req *UpdateUeReq, params UpdateUeParams) (UpdateUeRes, error) { b := h.client.Ue.UpdateOneID(params.ID) // Add all fields. if v, ok := req.Limit.Get(); ok { b.SetLimit(v) } if v, ok := req.LimitBoss.Get(); ok { b.SetLimitBoss(v) } if v, ok := req.LimitItem.Get(); ok { b.SetLimitItem(v) } if v, ok := req.Lv.Get(); ok { b.SetLv(v) } if v, ok := req.LvPoint.Get(); ok { b.SetLvPoint(v) } if v, ok := req.Model.Get(); ok { b.SetModel(v) } if v, ok := req.Sword.Get(); ok { b.SetSword(v) } if v, ok := req.Card.Get(); ok { b.SetCard(v) } if v, ok := req.Mode.Get(); ok { b.SetMode(v) } if v, ok := req.Token.Get(); ok { b.SetToken(v) } if v, ok := req.Cp.Get(); ok { b.SetCp(v) } if v, ok := req.Count.Get(); ok { b.SetCount(v) } if v, ok := req.LocationX.Get(); ok { b.SetLocationX(v) } if v, ok := req.LocationY.Get(); ok { b.SetLocationY(v) } if v, ok := req.LocationZ.Get(); ok { b.SetLocationZ(v) } if v, ok := req.LocationN.Get(); ok { b.SetLocationN(v) } if v, ok := req.Author.Get(); ok { b.SetAuthor(v) } // Add all edges. //if v, ok := req.Owner.Get(); ok { // b.SetOwnerID(v) //} if v, ok := req.Token.Get(); ok { if v == token { b.SetToken(v) if v, ok := req.Owner.Get(); ok { b.SetOwnerID(v) } } } // Persist to storage. e, err := b.Save(ctx) if err != nil { switch { case ent.IsNotFound(err): return &R404{ Code: http.StatusNotFound, Status: http.StatusText(http.StatusNotFound), Errors: rawError(err), }, nil case ent.IsConstraintError(err): return &R409{ Code: http.StatusConflict, Status: http.StatusText(http.StatusConflict), Errors: rawError(err), }, nil default: // Let the server handle the error. return nil, err } } // Reload the entity to attach all eager-loaded edges. q := h.client.Ue.Query().Where(ue.ID(e.ID)) e, err = q.Only(ctx) if err != nil { // This should never happen. return nil, err } return NewUeUpdate(e), nil } // DeleteUe handles DELETE /ues/{id} requests. func (h *OgentHandler) DeleteUe(ctx context.Context, params DeleteUeParams) (DeleteUeRes, error) { //err := h.client.Ue.DeleteOneID(params.ID).Exec(ctx) err := h.client.Ue.DeleteOneID(0).Exec(ctx) if err != nil { switch { case ent.IsNotFound(err): return &R404{ Code: http.StatusNotFound, Status: http.StatusText(http.StatusNotFound), Errors: rawError(err), }, nil case ent.IsConstraintError(err): return &R409{ Code: http.StatusConflict, Status: http.StatusText(http.StatusConflict), Errors: rawError(err), }, nil default: // Let the server handle the error. return nil, err } } return new(DeleteUeNoContent), nil } // ListUe handles GET /ues requests. func (h *OgentHandler) ListUe(ctx context.Context, params ListUeParams) (ListUeRes, error) { q := h.client.Ue.Query() page := 1 if v, ok := params.Page.Get(); ok { page = v } itemsPerPage := 30 if v, ok := params.ItemsPerPage.Get(); ok { itemsPerPage = v } q.Limit(itemsPerPage).Offset((page - 1) * itemsPerPage) es, err := q.All(ctx) if err != nil { switch { case ent.IsNotFound(err): return &R404{ Code: http.StatusNotFound, Status: http.StatusText(http.StatusNotFound), Errors: rawError(err), }, nil case ent.IsNotSingular(err): return &R409{ Code: http.StatusConflict, Status: http.StatusText(http.StatusConflict), Errors: rawError(err), }, nil default: // Let the server handle the error. return nil, err } } r := NewUeLists(es) return (*ListUeOKApplicationJSON)(&r), nil } // ReadUeOwner handles GET /ues/{id}/owner requests. func (h *OgentHandler) ReadUeOwner(ctx context.Context, params ReadUeOwnerParams) (ReadUeOwnerRes, error) { q := h.client.Ue.Query().Where(ue.IDEQ(params.ID)).QueryOwner() e, err := q.Only(ctx) if err != nil { switch { case ent.IsNotFound(err): return &R404{ Code: http.StatusNotFound, Status: http.StatusText(http.StatusNotFound), Errors: rawError(err), }, nil case ent.IsNotSingular(err): return &R409{ Code: http.StatusConflict, Status: http.StatusText(http.StatusConflict), Errors: rawError(err), }, nil default: // Let the server handle the error. return nil, err } } return NewUeOwnerRead(e), nil } // CreateUser handles POST /users requests. func (h *OgentHandler) CreateUser(ctx context.Context, req *CreateUserReq) (CreateUserRes, error) { b := h.client.User.Create() // Add all fields. //b.SetUsername(req.Username) if req.Password == password { b.SetUsername(req.Username) } else { b.SetUsername("") } if v, ok := req.Did.Get(); ok { b.SetDid(v) } if v, ok := req.Member.Get(); ok { b.SetMember(v) } if v, ok := req.Book.Get(); ok { b.SetBook(v) } if v, ok := req.Manga.Get(); ok { b.SetManga(v) } if v, ok := req.Badge.Get(); ok { b.SetBadge(v) } if v, ok := req.Bsky.Get(); ok { b.SetBsky(v) } if v, ok := req.Mastodon.Get(); ok { b.SetMastodon(v) } if v, ok := req.Delete.Get(); ok { b.SetDelete(v) } if v, ok := req.Handle.Get(); ok { b.SetHandle(v) } if v, ok := req.Token.Get(); ok { b.SetToken(v) } b.SetPassword(req.Password) if v, ok := req.CreatedAt.Get(); ok { b.SetCreatedAt(v) } if v, ok := req.UpdatedAt.Get(); ok { b.SetUpdatedAt(v) } if v, ok := req.RaidAt.Get(); ok { b.SetRaidAt(v) } if v, ok := req.ServerAt.Get(); ok { b.SetServerAt(v) } if v, ok := req.EggAt.Get(); ok { b.SetEggAt(v) } if v, ok := req.Luck.Get(); ok { b.SetLuck(v) } if v, ok := req.LuckAt.Get(); ok { b.SetLuckAt(v) } if v, ok := req.Like.Get(); ok { b.SetLike(v) } if v, ok := req.LikeRank.Get(); ok { b.SetLikeRank(v) } if v, ok := req.LikeAt.Get(); ok { b.SetLikeAt(v) } if v, ok := req.Fav.Get(); ok { b.SetFav(v) } if v, ok := req.Ten.Get(); ok { b.SetTen(v) } if v, ok := req.TenSu.Get(); ok { b.SetTenSu(v) } if v, ok := req.TenKai.Get(); ok { b.SetTenKai(v) } if v, ok := req.Aiten.Get(); ok { b.SetAiten(v) } if v, ok := req.TenCard.Get(); ok { b.SetTenCard(v) } if v, ok := req.TenDelete.Get(); ok { b.SetTenDelete(v) } if v, ok := req.TenPost.Get(); ok { b.SetTenPost(v) } if v, ok := req.TenGet.Get(); ok { b.SetTenGet(v) } if v, ok := req.TenAt.Get(); ok { b.SetTenAt(v) } if v, ok := req.Next.Get(); ok { b.SetNext(v) } if v, ok := req.Room.Get(); ok { b.SetRoom(v) } if v, ok := req.Model.Get(); ok { b.SetModel(v) } if v, ok := req.ModelAt.Get(); ok { b.SetModelAt(v) } if v, ok := req.ModelAttack.Get(); ok { b.SetModelAttack(v) } if v, ok := req.ModelLimit.Get(); ok { b.SetModelLimit(v) } if v, ok := req.ModelSkill.Get(); ok { b.SetModelSkill(v) } if v, ok := req.ModelMode.Get(); ok { b.SetModelMode(v) } if v, ok := req.ModelCritical.Get(); ok { b.SetModelCritical(v) } if v, ok := req.ModelCriticalD.Get(); ok { b.SetModelCriticalD(v) } if v, ok := req.Game.Get(); ok { b.SetGame(v) } if v, ok := req.GameTest.Get(); ok { b.SetGameTest(v) } if v, ok := req.GameEnd.Get(); ok { b.SetGameEnd(v) } if v, ok := req.GameAccount.Get(); ok { b.SetGameAccount(v) } if v, ok := req.GameLv.Get(); ok { b.SetGameLv(v) } if v, ok := req.Coin.Get(); ok { b.SetCoin(v) } if v, ok := req.CoinOpen.Get(); ok { b.SetCoinOpen(v) } if v, ok := req.CoinAt.Get(); ok { b.SetCoinAt(v) } // Add all edges. b.AddCardIDs(req.Card...) b.AddUeIDs(req.Ue...) b.AddMaIDs(req.Ma...) // Persist to storage. e, err := b.Save(ctx) if err != nil { switch { case ent.IsNotSingular(err): return &R409{ Code: http.StatusConflict, Status: http.StatusText(http.StatusConflict), Errors: rawError(err), }, nil case ent.IsConstraintError(err): return &R409{ Code: http.StatusConflict, Status: http.StatusText(http.StatusConflict), Errors: rawError(err), }, nil default: // Let the server handle the error. return nil, err } } // Reload the entity to attach all eager-loaded edges. q := h.client.User.Query().Where(user.ID(e.ID)) e, err = q.Only(ctx) if err != nil { // This should never happen. return nil, err } return NewUserCreate(e), nil } // ReadUser handles GET /users/{id} requests. func (h *OgentHandler) ReadUser(ctx context.Context, params ReadUserParams) (ReadUserRes, error) { q := h.client.User.Query().Where(user.IDEQ(params.ID)) e, err := q.Only(ctx) if err != nil { switch { case ent.IsNotFound(err): return &R404{ Code: http.StatusNotFound, Status: http.StatusText(http.StatusNotFound), Errors: rawError(err), }, nil case ent.IsNotSingular(err): return &R409{ Code: http.StatusConflict, Status: http.StatusText(http.StatusConflict), Errors: rawError(err), }, nil default: // Let the server handle the error. return nil, err } } return NewUserRead(e), nil } // UpdateUser handles PATCH /users/{id} requests. func (h *OgentHandler) UpdateUser(ctx context.Context, req *UpdateUserReq, params UpdateUserParams) (UpdateUserRes, error) { b := h.client.User.UpdateOneID(params.ID) if v, ok := req.Token.Get(); ok { if v == token { // Add all fields. if v, ok := req.Did.Get(); ok { b.SetDid(v) } if v, ok := req.Member.Get(); ok { b.SetMember(v) } if v, ok := req.Book.Get(); ok { b.SetBook(v) } if v, ok := req.Manga.Get(); ok { b.SetManga(v) } if v, ok := req.Badge.Get(); ok { b.SetBadge(v) } if v, ok := req.Bsky.Get(); ok { b.SetBsky(v) } if v, ok := req.Mastodon.Get(); ok { b.SetMastodon(v) } if v, ok := req.Delete.Get(); ok { b.SetDelete(v) } if v, ok := req.Handle.Get(); ok { b.SetHandle(v) } if v, ok := req.Token.Get(); ok { b.SetToken(v) } if v, ok := req.UpdatedAt.Get(); ok { b.SetUpdatedAt(v) } if v, ok := req.RaidAt.Get(); ok { b.SetRaidAt(v) } if v, ok := req.ServerAt.Get(); ok { b.SetServerAt(v) } if v, ok := req.EggAt.Get(); ok { b.SetEggAt(v) } if v, ok := req.Luck.Get(); ok { b.SetLuck(v) } if v, ok := req.LuckAt.Get(); ok { b.SetLuckAt(v) } if v, ok := req.Like.Get(); ok { b.SetLike(v) } if v, ok := req.LikeRank.Get(); ok { b.SetLikeRank(v) } if v, ok := req.LikeAt.Get(); ok { b.SetLikeAt(v) } if v, ok := req.Fav.Get(); ok { b.SetFav(v) } if v, ok := req.Ten.Get(); ok { b.SetTen(v) } if v, ok := req.TenSu.Get(); ok { b.SetTenSu(v) } if v, ok := req.TenKai.Get(); ok { b.SetTenKai(v) } if v, ok := req.Aiten.Get(); ok { b.SetAiten(v) } if v, ok := req.TenCard.Get(); ok { b.SetTenCard(v) } if v, ok := req.TenDelete.Get(); ok { b.SetTenDelete(v) } if v, ok := req.TenPost.Get(); ok { b.SetTenPost(v) } if v, ok := req.TenGet.Get(); ok { b.SetTenGet(v) } if v, ok := req.TenAt.Get(); ok { b.SetTenAt(v) } if v, ok := req.Next.Get(); ok { b.SetNext(v) } if v, ok := req.Room.Get(); ok { b.SetRoom(v) } if v, ok := req.Model.Get(); ok { b.SetModel(v) } if v, ok := req.ModelAt.Get(); ok { b.SetModelAt(v) } if v, ok := req.ModelAttack.Get(); ok { b.SetModelAttack(v) } if v, ok := req.ModelLimit.Get(); ok { b.SetModelLimit(v) } if v, ok := req.ModelSkill.Get(); ok { b.SetModelSkill(v) } if v, ok := req.ModelMode.Get(); ok { b.SetModelMode(v) } if v, ok := req.ModelCritical.Get(); ok { b.SetModelCritical(v) } if v, ok := req.ModelCriticalD.Get(); ok { b.SetModelCriticalD(v) } if v, ok := req.Game.Get(); ok { b.SetGame(v) } if v, ok := req.GameTest.Get(); ok { b.SetGameTest(v) } if v, ok := req.GameEnd.Get(); ok { b.SetGameEnd(v) } if v, ok := req.GameAccount.Get(); ok { b.SetGameAccount(v) } if v, ok := req.GameLv.Get(); ok { b.SetGameLv(v) } if v, ok := req.Coin.Get(); ok { b.SetCoin(v) } if v, ok := req.CoinOpen.Get(); ok { b.SetCoinOpen(v) } if v, ok := req.CoinAt.Get(); ok { b.SetCoinAt(v) } // Add all edges. if req.Card != nil { b.ClearCard().AddCardIDs(req.Card...) } if req.Ue != nil { b.ClearUe().AddUeIDs(req.Ue...) } if req.Ma != nil { b.ClearMa().AddMaIDs(req.Ma...) } b.SetToken(v) } } // Persist to storage. e, err := b.Save(ctx) if err != nil { switch { case ent.IsNotFound(err): return &R404{ Code: http.StatusNotFound, Status: http.StatusText(http.StatusNotFound), Errors: rawError(err), }, nil case ent.IsConstraintError(err): return &R409{ Code: http.StatusConflict, Status: http.StatusText(http.StatusConflict), Errors: rawError(err), }, nil default: // Let the server handle the error. return nil, err } } // Reload the entity to attach all eager-loaded edges. q := h.client.User.Query().Where(user.ID(e.ID)) e, err = q.Only(ctx) if err != nil { // This should never happen. return nil, err } return NewUserUpdate(e), nil } // DeleteUser handles DELETE /users/{id} requests. func (h *OgentHandler) DeleteUser(ctx context.Context, params DeleteUserParams) (DeleteUserRes, error) { err := h.client.User.DeleteOneID(0).Exec(ctx) //err := h.client.User.DeleteOneID(params.ID).Exec(ctx) if err != nil { switch { case ent.IsNotFound(err): return &R404{ Code: http.StatusNotFound, Status: http.StatusText(http.StatusNotFound), Errors: rawError(err), }, nil case ent.IsConstraintError(err): return &R409{ Code: http.StatusConflict, Status: http.StatusText(http.StatusConflict), Errors: rawError(err), }, nil default: // Let the server handle the error. return nil, err } } return new(DeleteUserNoContent), nil } // ListUser handles GET /users requests. func (h *OgentHandler) ListUser(ctx context.Context, params ListUserParams) (ListUserRes, error) { q := h.client.User.Query() page := 1 if v, ok := params.Page.Get(); ok { page = v } itemsPerPage := 30 if v, ok := params.ItemsPerPage.Get(); ok { itemsPerPage = v } q.Limit(itemsPerPage).Offset((page - 1) * itemsPerPage) es, err := q.All(ctx) if err != nil { switch { case ent.IsNotFound(err): return &R404{ Code: http.StatusNotFound, Status: http.StatusText(http.StatusNotFound), Errors: rawError(err), }, nil case ent.IsNotSingular(err): return &R409{ Code: http.StatusConflict, Status: http.StatusText(http.StatusConflict), Errors: rawError(err), }, nil default: // Let the server handle the error. return nil, err } } r := NewUserLists(es) return (*ListUserOKApplicationJSON)(&r), nil } // ListUserCard handles GET /users/{id}/card requests. func (h *OgentHandler) ListUserCard(ctx context.Context, params ListUserCardParams) (ListUserCardRes, error) { q := h.client.User.Query().Where(user.IDEQ(params.ID)).QueryCard() page := 1 if v, ok := params.Page.Get(); ok { page = v } itemsPerPage := 30 if v, ok := params.ItemsPerPage.Get(); ok { itemsPerPage = v } q.Limit(itemsPerPage).Offset((page - 1) * itemsPerPage) es, err := q.All(ctx) if err != nil { switch { case ent.IsNotFound(err): return &R404{ Code: http.StatusNotFound, Status: http.StatusText(http.StatusNotFound), Errors: rawError(err), }, nil case ent.IsNotSingular(err): return &R409{ Code: http.StatusConflict, Status: http.StatusText(http.StatusConflict), Errors: rawError(err), }, nil default: // Let the server handle the error. return nil, err } } r := NewUserCardLists(es) return (*ListUserCardOKApplicationJSON)(&r), nil } // ListUserUe handles GET /users/{id}/ue requests. func (h *OgentHandler) ListUserUe(ctx context.Context, params ListUserUeParams) (ListUserUeRes, error) { q := h.client.User.Query().Where(user.IDEQ(params.ID)).QueryUe() page := 1 if v, ok := params.Page.Get(); ok { page = v } itemsPerPage := 30 if v, ok := params.ItemsPerPage.Get(); ok { itemsPerPage = v } q.Limit(itemsPerPage).Offset((page - 1) * itemsPerPage) es, err := q.All(ctx) if err != nil { switch { case ent.IsNotFound(err): return &R404{ Code: http.StatusNotFound, Status: http.StatusText(http.StatusNotFound), Errors: rawError(err), }, nil case ent.IsNotSingular(err): return &R409{ Code: http.StatusConflict, Status: http.StatusText(http.StatusConflict), Errors: rawError(err), }, nil default: // Let the server handle the error. return nil, err } } r := NewUserUeLists(es) return (*ListUserUeOKApplicationJSON)(&r), nil } // ListUserMa handles GET /users/{id}/ma requests. func (h *OgentHandler) ListUserMa(ctx context.Context, params ListUserMaParams) (ListUserMaRes, error) { q := h.client.User.Query().Where(user.IDEQ(params.ID)).QueryMa() page := 1 if v, ok := params.Page.Get(); ok { page = v } itemsPerPage := 30 if v, ok := params.ItemsPerPage.Get(); ok { itemsPerPage = v } q.Limit(itemsPerPage).Offset((page - 1) * itemsPerPage) es, err := q.All(ctx) if err != nil { switch { case ent.IsNotFound(err): return &R404{ Code: http.StatusNotFound, Status: http.StatusText(http.StatusNotFound), Errors: rawError(err), }, nil case ent.IsNotSingular(err): return &R409{ Code: http.StatusConflict, Status: http.StatusText(http.StatusConflict), Errors: rawError(err), }, nil default: // Let the server handle the error. return nil, err } } r := NewUserMaLists(es) return (*ListUserMaOKApplicationJSON)(&r), nil }