netbird/dex
0
0
Fork 0
mirror of https://github.com/netbirdio/dex.git synced 2026-05-22 18:43:53 -07:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #4276 from dexidp/update-ent

Browse Source 
chore: update ent generated code
This commit is contained in:
Márk Sági-Kazár
2025-08-18 13:14:34 +02:00
committed by GitHub
parent 7fed24ec48 1b548e853d
commit 3d750b9c11
55 changed files with 4804 additions and 4807 deletions
Download Patch File Download Diff File Expand all files Collapse all files
go.mod
+5 -6
View File
@@ -4,7 +4,7 @@ go 1.24.0
require (
cloud.google.com/go/compute/metadata v0.8.0
entgo.io/ent v0.14.4
entgo.io/ent v0.14.5
github.com/AppsFlyer/go-sundheit v0.6.0
github.com/Masterminds/semver v1.5.0
github.com/Masterminds/sprig/v3 v3.3.0
@@ -42,7 +42,7 @@ require (
)
require (
ariga.io/atlas v0.31.1-0.20250212144724-069be8033e83 // indirect
ariga.io/atlas v0.32.1-0.20250325101103-175b25e1c1b9 // indirect
cloud.google.com/go/auth v0.16.4 // indirect
cloud.google.com/go/auth/oauth2adapt v0.2.8 // indirect
dario.cat/mergo v1.0.1 // indirect
@@ -50,8 +50,7 @@ require (
github.com/Azure/go-ntlmssp v0.0.0-20221128193559-754e69321358 // indirect
github.com/Masterminds/goutils v1.1.1 // indirect
github.com/Masterminds/semver/v3 v3.3.0 // indirect
github.com/agext/levenshtein v1.2.1 // indirect
github.com/apparentlymart/go-textseg/v13 v13.0.0 // indirect
github.com/agext/levenshtein v1.2.3 // indirect
github.com/apparentlymart/go-textseg/v15 v15.0.0 // indirect
github.com/beorn7/perks v1.0.1 // indirect
github.com/bmatcuk/doublestar v1.3.4 // indirect
@@ -71,13 +70,13 @@ require (
github.com/googleapis/enterprise-certificate-proxy v0.3.6 // indirect
github.com/googleapis/gax-go/v2 v2.15.0 // indirect
github.com/grpc-ecosystem/grpc-gateway/v2 v2.26.3 // indirect
github.com/hashicorp/hcl/v2 v2.13.0 // indirect
github.com/hashicorp/hcl/v2 v2.18.1 // indirect
github.com/huandu/xstrings v1.5.0 // indirect
github.com/inconshreveable/mousetrap v1.1.0 // indirect
github.com/jonboulle/clockwork v0.5.0 // indirect
github.com/mattn/go-runewidth v0.0.9 // indirect
github.com/mitchellh/copystructure v1.2.0 // indirect
github.com/mitchellh/go-wordwrap v0.0.0-20150314170334-ad45545899c7 // indirect
github.com/mitchellh/go-wordwrap v1.0.1 // indirect
github.com/mitchellh/reflectwalk v1.0.2 // indirect
github.com/munnerz/goautoneg v0.0.0-20191010083416-a7dc8b61c822 // indirect
github.com/olekukonko/tablewriter v0.0.5 // indirect
go.sum
+12 -14
View File
@@ -1,5 +1,5 @@
ariga.io/atlas v0.31.1-0.20250212144724-069be8033e83 h1:nX4HXncwIdvQ8/8sIUIf1nyCkK8qdBaHQ7EtzPpuiGE=
ariga.io/atlas v0.31.1-0.20250212144724-069be8033e83/go.mod h1:Oe1xWPuu5q9LzyrWfbZmEZxFYeu4BHTyzfjeW2aZp/w=
ariga.io/atlas v0.32.1-0.20250325101103-175b25e1c1b9 h1:E0wvcUXTkgyN4wy4LGtNzMNGMytJN8afmIWXJVMi4cc=
ariga.io/atlas v0.32.1-0.20250325101103-175b25e1c1b9/go.mod h1:Oe1xWPuu5q9LzyrWfbZmEZxFYeu4BHTyzfjeW2aZp/w=
cloud.google.com/go/auth v0.16.4 h1:fXOAIQmkApVvcIn7Pc2+5J8QTMVbUGLscnSVNl11su8=
cloud.google.com/go/auth v0.16.4/go.mod h1:j10ncYwjX/g3cdX7GpEzsdM+d+ZNsXAbb6qXA7p1Y5M=
cloud.google.com/go/auth/oauth2adapt v0.2.8 h1:keo8NaayQZ6wimpNSmW5OPc283g65QNIiLpZnkHRbnc=
@@ -8,8 +8,8 @@ cloud.google.com/go/compute/metadata v0.8.0 h1:HxMRIbao8w17ZX6wBnjhcDkW6lTFpgcao
cloud.google.com/go/compute/metadata v0.8.0/go.mod h1:sYOGTp851OV9bOFJ9CH7elVvyzopvWQFNNghtDQ/Biw=
dario.cat/mergo v1.0.1 h1:Ra4+bf83h2ztPIQYNP99R6m+Y7KfnARDfID+a+vLl4s=
dario.cat/mergo v1.0.1/go.mod h1:uNxQE+84aUszobStD9th8a29P2fMDhsBdgRYvZOxGmk=
entgo.io/ent v0.14.4 h1:/DhDraSLXIkBhyiVoJeSshr4ZYi7femzhj6/TckzZuI=
entgo.io/ent v0.14.4/go.mod h1:aDPE/OziPEu8+OWbzy4UlvWmD2/kbRuWfK2A40hcxJM=
entgo.io/ent v0.14.5 h1:Rj2WOYJtCkWyFo6a+5wB3EfBRP0rnx1fMk6gGA0UUe4=
entgo.io/ent v0.14.5/go.mod h1:zTzLmWtPvGpmSwtkaayM2cm5m819NdM7z7tYPq3vN0U=
filippo.io/edwards25519 v1.1.0 h1:FNf4tywRC1HmFuKW5xopWpigGjJKiJSV0Cqo0cJWDaA=
filippo.io/edwards25519 v1.1.0/go.mod h1:BxyFTGdWcka3PhytdK4V28tE5sGfRvvvRV7EaN4VDT4=
github.com/AppsFlyer/go-sundheit v0.6.0 h1:d2hBvCjBSb2lUsEWGfPigr4MCOt04sxB+Rppl0yUMSk=
@@ -26,12 +26,10 @@ github.com/Masterminds/semver/v3 v3.3.0 h1:B8LGeaivUe71a5qox1ICM/JLl0NqZSW5CHyL+
github.com/Masterminds/semver/v3 v3.3.0/go.mod h1:4V+yj/TJE1HU9XfppCwVMZq3I84lprf4nC11bSS5beM=
github.com/Masterminds/sprig/v3 v3.3.0 h1:mQh0Yrg1XPo6vjYXgtf5OtijNAKJRNcTdOOGZe3tPhs=
github.com/Masterminds/sprig/v3 v3.3.0/go.mod h1:Zy1iXRYNqNLUolqCpL4uhk6SHUMAOSCzdgBfDb35Lz0=
github.com/agext/levenshtein v1.2.1 h1:QmvMAjj2aEICytGiWzmxoE0x2KZvE0fvmqMOfy2tjT8=
github.com/agext/levenshtein v1.2.1/go.mod h1:JEDfjyjHDjOF/1e4FlBE/PkbqA9OfWu2ki2W0IB5558=
github.com/agext/levenshtein v1.2.3 h1:YB2fHEn0UJagG8T1rrWknE3ZQzWM06O8AMAatNn7lmo=
github.com/agext/levenshtein v1.2.3/go.mod h1:JEDfjyjHDjOF/1e4FlBE/PkbqA9OfWu2ki2W0IB5558=
github.com/alexbrainman/sspi v0.0.0-20231016080023-1a75b4708caa h1:LHTHcTQiSGT7VVbI0o4wBRNQIgn917usHWOd6VAffYI=
github.com/alexbrainman/sspi v0.0.0-20231016080023-1a75b4708caa/go.mod h1:cEWa1LVoE5KvSD9ONXsZrj0z6KqySlCCNKHlLzbqAt4=
github.com/apparentlymart/go-textseg/v13 v13.0.0 h1:Y+KvPE1NYz0xl601PVImeQfFyEy6iT90AvPUL1NNfNw=
github.com/apparentlymart/go-textseg/v13 v13.0.0/go.mod h1:ZK2fH7c4NqDTLtiYLvIkEghdlcqw7yxLeM89kiTRPUo=
github.com/apparentlymart/go-textseg/v15 v15.0.0 h1:uYvfpb3DyLSCGWnctWKGj857c6ew1u1fNQOlOtuGxQY=
github.com/apparentlymart/go-textseg/v15 v15.0.0/go.mod h1:K8XmNZdhEBkdlyDdvbmmsvpAG721bKi0joRfFdHIWJ4=
github.com/beevik/etree v1.5.1 h1:TC3zyxYp+81wAmbsi8SWUpZCurbxa6S8RITYRSkNRwo=
@@ -104,8 +102,8 @@ github.com/grpc-ecosystem/grpc-gateway/v2 v2.26.3 h1:5ZPtiqj0JL5oKWmcsq4VMaAW5uk
github.com/grpc-ecosystem/grpc-gateway/v2 v2.26.3/go.mod h1:ndYquD05frm2vACXE1nsccT4oJzjhw2arTS2cpUD1PI=
github.com/hashicorp/go-uuid v1.0.3 h1:2gKiV6YVmrJ1i2CKKa9obLvRieoRGviZFL26PcT/Co8=
github.com/hashicorp/go-uuid v1.0.3/go.mod h1:6SBZvOh/SIDV7/2o3Jml5SYk/TvGqwFJ/bN7x4byOro=
github.com/hashicorp/hcl/v2 v2.13.0 h1:0Apadu1w6M11dyGFxWnmhhcMjkbAiKCv7G1r/2QgCNc=
github.com/hashicorp/hcl/v2 v2.13.0/go.mod h1:e4z5nxYlWNPdDSNYX+ph14EvWYMFm3eP0zIUqPc2jr0=
github.com/hashicorp/hcl/v2 v2.18.1 h1:6nxnOJFku1EuSawSD81fuviYUV8DxFr3fp2dUi3ZYSo=
github.com/hashicorp/hcl/v2 v2.18.1/go.mod h1:ThLC89FV4p9MPW804KVbe/cEXoQ8NZEh+JtMeeGErHE=
github.com/huandu/xstrings v1.5.0 h1:2ag3IFq9ZDANvthTwTiqSSZLjDc+BedvHPAp5tJy2TI=
github.com/huandu/xstrings v1.5.0/go.mod h1:y5/lhBue+AyNmUVz9RLU9xbLR0o4KIIExikq4ovT0aE=
github.com/inconshreveable/mousetrap v1.1.0 h1:wN+x4NVGpMsO7ErUn/mUI3vEoE6Jt13X2s0bqwp9tc8=
@@ -147,8 +145,8 @@ github.com/mattn/go-sqlite3 v1.14.32 h1:JD12Ag3oLy1zQA+BNn74xRgaBbdhbNIDYvQUEuuE
github.com/mattn/go-sqlite3 v1.14.32/go.mod h1:Uh1q+B4BYcTPb+yiD3kU8Ct7aC0hY9fxUwlHK0RXw+Y=
github.com/mitchellh/copystructure v1.2.0 h1:vpKXTN4ewci03Vljg/q9QvCGUDttBOGBIa15WveJJGw=
github.com/mitchellh/copystructure v1.2.0/go.mod h1:qLl+cE2AmVv+CoeAwDPye/v+N2HKCj9FbZEVFJRxO9s=
github.com/mitchellh/go-wordwrap v0.0.0-20150314170334-ad45545899c7 h1:DpOJ2HYzCv8LZP15IdmG+YdwD2luVPHITV96TkirNBM=
github.com/mitchellh/go-wordwrap v0.0.0-20150314170334-ad45545899c7/go.mod h1:ZXFpozHsX6DPmq2I0TCekCxypsnAUbP2oI0UX1GXzOo=
github.com/mitchellh/go-wordwrap v1.0.1 h1:TLuKupo69TCn6TQSyGxwI1EblZZEsQ0vMlAFQflz0v0=
github.com/mitchellh/go-wordwrap v1.0.1/go.mod h1:R62XHJLzvMFRBbcrT7m7WgmE1eOyTSsCt+hzestvNj0=
github.com/mitchellh/reflectwalk v1.0.2 h1:G2LzWKi524PWgd3mLHV8Y5k7s6XUvT0Gef6zxSIeXaQ=
github.com/mitchellh/reflectwalk v1.0.2/go.mod h1:mSTlrgnPZtwu0c4WaC2kGObEpuNDbx0jmZXqmk4esnw=
github.com/munnerz/goautoneg v0.0.0-20191010083416-a7dc8b61c822 h1:C3w9PqII01/Oq1c1nUAm88MOHcQC9l5mIlSMApZMrHA=
@@ -175,8 +173,8 @@ github.com/rogpeppe/go-internal v1.13.1/go.mod h1:uMEvuHeurkdAXX61udpOXGD/AzZDWN
github.com/russellhaering/goxmldsig v1.5.0 h1:AU2UkkYIUOTyZRbe08XMThaOCelArgvNfYapcmSjBNw=
github.com/russellhaering/goxmldsig v1.5.0/go.mod h1:x98CjQNFJcWfMxeOrMnMKg70lvDP6tE0nTaeUnjXDmk=
github.com/russross/blackfriday/v2 v2.1.0/go.mod h1:+Rmxgy9KzJVeS9/2gXHxylqXiyQDYRxCVz55jmeOWTM=
github.com/sergi/go-diff v1.0.0 h1:Kpca3qRNrduNnOQeazBd0ysaKrUJiIuISHxogkT9RPQ=
github.com/sergi/go-diff v1.0.0/go.mod h1:0CfEIISq7TuYL3j771MWULgwwjU+GofnZX9QAmXWZgo=
github.com/sergi/go-diff v1.3.1 h1:xkr+Oxo4BOQKmkn/B9eMK0g5Kg/983T9DqqPHwYqD+8=
github.com/sergi/go-diff v1.3.1/go.mod h1:aMJSSKb2lpPvRNec0+w3fl7LP9IOFzdc9Pa4NFbPK1I=
github.com/shopspring/decimal v1.4.0 h1:bxl37RwXBklmTi0C79JfXCEBD1cqqHt0bbgBAGFp81k=
github.com/shopspring/decimal v1.4.0/go.mod h1:gawqmDU56v4yIKSwfBSFip1HdCCXN8/+DMd9qYNcwME=
github.com/spf13/cast v1.7.0 h1:ntdiHjuueXFgm5nzDRdOS4yfT43P5Fnud6DH50rz/7w=
storage/ent/db/authcode.go
+43 -43
View File
@@ -73,7 +73,7 @@ func (*AuthCode) scanValues(columns []string) ([]any, error) {
// assignValues assigns the values that were returned from sql.Rows (after scanning)
// to the AuthCode fields.
func (ac *AuthCode) assignValues(columns []string, values []any) error {
func (_m *AuthCode) assignValues(columns []string, values []any) error {
if m, n := len(values), len(columns); m < n {
return fmt.Errorf("mismatch number of scan values: %d != %d", m, n)
}
@@ -83,19 +83,19 @@ func (ac *AuthCode) assignValues(columns []string, values []any) error {
if value, ok := values[i].(*sql.NullString); !ok {
return fmt.Errorf("unexpected type %T for field id", values[i])
} else if value.Valid {
ac.ID = value.String
_m.ID = value.String
}
case authcode.FieldClientID:
if value, ok := values[i].(*sql.NullString); !ok {
return fmt.Errorf("unexpected type %T for field client_id", values[i])
} else if value.Valid {
ac.ClientID = value.String
_m.ClientID = value.String
}
case authcode.FieldScopes:
if value, ok := values[i].(*[]byte); !ok {
return fmt.Errorf("unexpected type %T for field scopes", values[i])
} else if value != nil && len(*value) > 0 {
if err := json.Unmarshal(*value, &ac.Scopes); err != nil {
if err := json.Unmarshal(*value, &_m.Scopes); err != nil {
return fmt.Errorf("unmarshal field scopes: %w", err)
}
}
@@ -103,43 +103,43 @@ func (ac *AuthCode) assignValues(columns []string, values []any) error {
if value, ok := values[i].(*sql.NullString); !ok {
return fmt.Errorf("unexpected type %T for field nonce", values[i])
} else if value.Valid {
ac.Nonce = value.String
_m.Nonce = value.String
}
case authcode.FieldRedirectURI:
if value, ok := values[i].(*sql.NullString); !ok {
return fmt.Errorf("unexpected type %T for field redirect_uri", values[i])
} else if value.Valid {
ac.RedirectURI = value.String
_m.RedirectURI = value.String
}
case authcode.FieldClaimsUserID:
if value, ok := values[i].(*sql.NullString); !ok {
return fmt.Errorf("unexpected type %T for field claims_user_id", values[i])
} else if value.Valid {
ac.ClaimsUserID = value.String
_m.ClaimsUserID = value.String
}
case authcode.FieldClaimsUsername:
if value, ok := values[i].(*sql.NullString); !ok {
return fmt.Errorf("unexpected type %T for field claims_username", values[i])
} else if value.Valid {
ac.ClaimsUsername = value.String
_m.ClaimsUsername = value.String
}
case authcode.FieldClaimsEmail:
if value, ok := values[i].(*sql.NullString); !ok {
return fmt.Errorf("unexpected type %T for field claims_email", values[i])
} else if value.Valid {
ac.ClaimsEmail = value.String
_m.ClaimsEmail = value.String
}
case authcode.FieldClaimsEmailVerified:
if value, ok := values[i].(*sql.NullBool); !ok {
return fmt.Errorf("unexpected type %T for field claims_email_verified", values[i])
} else if value.Valid {
ac.ClaimsEmailVerified = value.Bool
_m.ClaimsEmailVerified = value.Bool
}
case authcode.FieldClaimsGroups:
if value, ok := values[i].(*[]byte); !ok {
return fmt.Errorf("unexpected type %T for field claims_groups", values[i])
} else if value != nil && len(*value) > 0 {
if err := json.Unmarshal(*value, &ac.ClaimsGroups); err != nil {
if err := json.Unmarshal(*value, &_m.ClaimsGroups); err != nil {
return fmt.Errorf("unmarshal field claims_groups: %w", err)
}
}
@@ -147,40 +147,40 @@ func (ac *AuthCode) assignValues(columns []string, values []any) error {
if value, ok := values[i].(*sql.NullString); !ok {
return fmt.Errorf("unexpected type %T for field claims_preferred_username", values[i])
} else if value.Valid {
ac.ClaimsPreferredUsername = value.String
_m.ClaimsPreferredUsername = value.String
}
case authcode.FieldConnectorID:
if value, ok := values[i].(*sql.NullString); !ok {
return fmt.Errorf("unexpected type %T for field connector_id", values[i])
} else if value.Valid {
ac.ConnectorID = value.String
_m.ConnectorID = value.String
}
case authcode.FieldConnectorData:
if value, ok := values[i].(*[]byte); !ok {
return fmt.Errorf("unexpected type %T for field connector_data", values[i])
} else if value != nil {
ac.ConnectorData = value
_m.ConnectorData = value
}
case authcode.FieldExpiry:
if value, ok := values[i].(*sql.NullTime); !ok {
return fmt.Errorf("unexpected type %T for field expiry", values[i])
} else if value.Valid {
ac.Expiry = value.Time
_m.Expiry = value.Time
}
case authcode.FieldCodeChallenge:
if value, ok := values[i].(*sql.NullString); !ok {
return fmt.Errorf("unexpected type %T for field code_challenge", values[i])
} else if value.Valid {
ac.CodeChallenge = value.String
_m.CodeChallenge = value.String
}
case authcode.FieldCodeChallengeMethod:
if value, ok := values[i].(*sql.NullString); !ok {
return fmt.Errorf("unexpected type %T for field code_challenge_method", values[i])
} else if value.Valid {
ac.CodeChallengeMethod = value.String
_m.CodeChallengeMethod = value.String
}
default:
ac.selectValues.Set(columns[i], values[i])
_m.selectValues.Set(columns[i], values[i])
}
}
return nil
@@ -188,79 +188,79 @@ func (ac *AuthCode) assignValues(columns []string, values []any) error {
// Value returns the ent.Value that was dynamically selected and assigned to the AuthCode.
// This includes values selected through modifiers, order, etc.
func (ac *AuthCode) Value(name string) (ent.Value, error) {
return ac.selectValues.Get(name)
func (_m *AuthCode) Value(name string) (ent.Value, error) {
return _m.selectValues.Get(name)
}
// Update returns a builder for updating this AuthCode.
// Note that you need to call AuthCode.Unwrap() before calling this method if this AuthCode
// was returned from a transaction, and the transaction was committed or rolled back.
func (ac *AuthCode) Update() *AuthCodeUpdateOne {
return NewAuthCodeClient(ac.config).UpdateOne(ac)
func (_m *AuthCode) Update() *AuthCodeUpdateOne {
return NewAuthCodeClient(_m.config).UpdateOne(_m)
}
// Unwrap unwraps the AuthCode entity that was returned from a transaction after it was closed,
// so that all future queries will be executed through the driver which created the transaction.
func (ac *AuthCode) Unwrap() *AuthCode {
_tx, ok := ac.config.driver.(*txDriver)
func (_m *AuthCode) Unwrap() *AuthCode {
_tx, ok := _m.config.driver.(*txDriver)
if !ok {
panic("db: AuthCode is not a transactional entity")
}
ac.config.driver = _tx.drv
return ac
_m.config.driver = _tx.drv
return _m
}
// String implements the fmt.Stringer.
func (ac *AuthCode) String() string {
func (_m *AuthCode) String() string {
var builder strings.Builder
builder.WriteString("AuthCode(")
builder.WriteString(fmt.Sprintf("id=%v, ", ac.ID))
builder.WriteString(fmt.Sprintf("id=%v, ", _m.ID))
builder.WriteString("client_id=")
builder.WriteString(ac.ClientID)
builder.WriteString(_m.ClientID)
builder.WriteString(", ")
builder.WriteString("scopes=")
builder.WriteString(fmt.Sprintf("%v", ac.Scopes))
builder.WriteString(fmt.Sprintf("%v", _m.Scopes))
builder.WriteString(", ")
builder.WriteString("nonce=")
builder.WriteString(ac.Nonce)
builder.WriteString(_m.Nonce)
builder.WriteString(", ")
builder.WriteString("redirect_uri=")
builder.WriteString(ac.RedirectURI)
builder.WriteString(_m.RedirectURI)
builder.WriteString(", ")
builder.WriteString("claims_user_id=")
builder.WriteString(ac.ClaimsUserID)
builder.WriteString(_m.ClaimsUserID)
builder.WriteString(", ")
builder.WriteString("claims_username=")
builder.WriteString(ac.ClaimsUsername)
builder.WriteString(_m.ClaimsUsername)
builder.WriteString(", ")
builder.WriteString("claims_email=")
builder.WriteString(ac.ClaimsEmail)
builder.WriteString(_m.ClaimsEmail)
builder.WriteString(", ")
builder.WriteString("claims_email_verified=")
builder.WriteString(fmt.Sprintf("%v", ac.ClaimsEmailVerified))
builder.WriteString(fmt.Sprintf("%v", _m.ClaimsEmailVerified))
builder.WriteString(", ")
builder.WriteString("claims_groups=")
builder.WriteString(fmt.Sprintf("%v", ac.ClaimsGroups))
builder.WriteString(fmt.Sprintf("%v", _m.ClaimsGroups))
builder.WriteString(", ")
builder.WriteString("claims_preferred_username=")
builder.WriteString(ac.ClaimsPreferredUsername)
builder.WriteString(_m.ClaimsPreferredUsername)
builder.WriteString(", ")
builder.WriteString("connector_id=")
builder.WriteString(ac.ConnectorID)
builder.WriteString(_m.ConnectorID)
builder.WriteString(", ")
if v := ac.ConnectorData; v != nil {
if v := _m.ConnectorData; v != nil {
builder.WriteString("connector_data=")
builder.WriteString(fmt.Sprintf("%v", *v))
}
builder.WriteString(", ")
builder.WriteString("expiry=")
builder.WriteString(ac.Expiry.Format(time.ANSIC))
builder.WriteString(_m.Expiry.Format(time.ANSIC))
builder.WriteString(", ")
builder.WriteString("code_challenge=")
builder.WriteString(ac.CodeChallenge)
builder.WriteString(_m.CodeChallenge)
builder.WriteString(", ")
builder.WriteString("code_challenge_method=")
builder.WriteString(ac.CodeChallengeMethod)
builder.WriteString(_m.CodeChallengeMethod)
builder.WriteByte(')')
return builder.String()
}
storage/ent/db/authcode_create.go
+140 -140
View File
File diff suppressed because it is too large Load Diff
storage/ent/db/authcode_delete.go
+19 -19
View File
@@ -20,56 +20,56 @@ type AuthCodeDelete struct {
}
// Where appends a list predicates to the AuthCodeDelete builder.
func (acd *AuthCodeDelete) Where(ps ...predicate.AuthCode) *AuthCodeDelete {
acd.mutation.Where(ps...)
return acd
func (_d *AuthCodeDelete) Where(ps ...predicate.AuthCode) *AuthCodeDelete {
_d.mutation.Where(ps...)
return _d
}
// Exec executes the deletion query and returns how many vertices were deleted.
func (acd *AuthCodeDelete) Exec(ctx context.Context) (int, error) {
return withHooks(ctx, acd.sqlExec, acd.mutation, acd.hooks)
func (_d *AuthCodeDelete) Exec(ctx context.Context) (int, error) {
return withHooks(ctx, _d.sqlExec, _d.mutation, _d.hooks)
}
// ExecX is like Exec, but panics if an error occurs.
func (acd *AuthCodeDelete) ExecX(ctx context.Context) int {
n, err := acd.Exec(ctx)
func (_d *AuthCodeDelete) ExecX(ctx context.Context) int {
n, err := _d.Exec(ctx)
if err != nil {
panic(err)
}
return n
}
func (acd *AuthCodeDelete) sqlExec(ctx context.Context) (int, error) {
func (_d *AuthCodeDelete) sqlExec(ctx context.Context) (int, error) {
_spec := sqlgraph.NewDeleteSpec(authcode.Table, sqlgraph.NewFieldSpec(authcode.FieldID, field.TypeString))
if ps := acd.mutation.predicates; len(ps) > 0 {
if ps := _d.mutation.predicates; len(ps) > 0 {
_spec.Predicate = func(selector *sql.Selector) {
for i := range ps {
ps[i](selector)
}
}
}
affected, err := sqlgraph.DeleteNodes(ctx, acd.driver, _spec)
affected, err := sqlgraph.DeleteNodes(ctx, _d.driver, _spec)
if err != nil && sqlgraph.IsConstraintError(err) {
err = &ConstraintError{msg: err.Error(), wrap: err}
}
acd.mutation.done = true
_d.mutation.done = true
return affected, err
}
// AuthCodeDeleteOne is the builder for deleting a single AuthCode entity.
type AuthCodeDeleteOne struct {
acd *AuthCodeDelete
_d *AuthCodeDelete
}
// Where appends a list predicates to the AuthCodeDelete builder.
func (acdo *AuthCodeDeleteOne) Where(ps ...predicate.AuthCode) *AuthCodeDeleteOne {
acdo.acd.mutation.Where(ps...)
return acdo
func (_d *AuthCodeDeleteOne) Where(ps ...predicate.AuthCode) *AuthCodeDeleteOne {
_d._d.mutation.Where(ps...)
return _d
}
// Exec executes the deletion query.
func (acdo *AuthCodeDeleteOne) Exec(ctx context.Context) error {
n, err := acdo.acd.Exec(ctx)
func (_d *AuthCodeDeleteOne) Exec(ctx context.Context) error {
n, err := _d._d.Exec(ctx)
switch {
case err != nil:
return err
@@ -81,8 +81,8 @@ func (acdo *AuthCodeDeleteOne) Exec(ctx context.Context) error {
}
// ExecX is like Exec, but panics if an error occurs.
func (acdo *AuthCodeDeleteOne) ExecX(ctx context.Context) {
if err := acdo.Exec(ctx); err != nil {
func (_d *AuthCodeDeleteOne) ExecX(ctx context.Context) {
if err := _d.Exec(ctx); err != nil {
panic(err)
}
}
storage/ent/db/authcode_query.go
+136 -136
View File
File diff suppressed because it is too large Load Diff
storage/ent/db/authcode_update.go
+320 -320
View File
File diff suppressed because it is too large Load Diff
storage/ent/db/authrequest.go
+53 -53
View File
@@ -83,7 +83,7 @@ func (*AuthRequest) scanValues(columns []string) ([]any, error) {
// assignValues assigns the values that were returned from sql.Rows (after scanning)
// to the AuthRequest fields.
func (ar *AuthRequest) assignValues(columns []string, values []any) error {
func (_m *AuthRequest) assignValues(columns []string, values []any) error {
if m, n := len(values), len(columns); m < n {
return fmt.Errorf("mismatch number of scan values: %d != %d", m, n)
}
@@ -93,19 +93,19 @@ func (ar *AuthRequest) assignValues(columns []string, values []any) error {
if value, ok := values[i].(*sql.NullString); !ok {
return fmt.Errorf("unexpected type %T for field id", values[i])
} else if value.Valid {
ar.ID = value.String
_m.ID = value.String
}
case authrequest.FieldClientID:
if value, ok := values[i].(*sql.NullString); !ok {
return fmt.Errorf("unexpected type %T for field client_id", values[i])
} else if value.Valid {
ar.ClientID = value.String
_m.ClientID = value.String
}
case authrequest.FieldScopes:
if value, ok := values[i].(*[]byte); !ok {
return fmt.Errorf("unexpected type %T for field scopes", values[i])
} else if value != nil && len(*value) > 0 {
if err := json.Unmarshal(*value, &ar.Scopes); err != nil {
if err := json.Unmarshal(*value, &_m.Scopes); err != nil {
return fmt.Errorf("unmarshal field scopes: %w", err)
}
}
@@ -113,7 +113,7 @@ func (ar *AuthRequest) assignValues(columns []string, values []any) error {
if value, ok := values[i].(*[]byte); !ok {
return fmt.Errorf("unexpected type %T for field response_types", values[i])
} else if value != nil && len(*value) > 0 {
if err := json.Unmarshal(*value, &ar.ResponseTypes); err != nil {
if err := json.Unmarshal(*value, &_m.ResponseTypes); err != nil {
return fmt.Errorf("unmarshal field response_types: %w", err)
}
}
@@ -121,61 +121,61 @@ func (ar *AuthRequest) assignValues(columns []string, values []any) error {
if value, ok := values[i].(*sql.NullString); !ok {
return fmt.Errorf("unexpected type %T for field redirect_uri", values[i])
} else if value.Valid {
ar.RedirectURI = value.String
_m.RedirectURI = value.String
}
case authrequest.FieldNonce:
if value, ok := values[i].(*sql.NullString); !ok {
return fmt.Errorf("unexpected type %T for field nonce", values[i])
} else if value.Valid {
ar.Nonce = value.String
_m.Nonce = value.String
}
case authrequest.FieldState:
if value, ok := values[i].(*sql.NullString); !ok {
return fmt.Errorf("unexpected type %T for field state", values[i])
} else if value.Valid {
ar.State = value.String
_m.State = value.String
}
case authrequest.FieldForceApprovalPrompt:
if value, ok := values[i].(*sql.NullBool); !ok {
return fmt.Errorf("unexpected type %T for field force_approval_prompt", values[i])
} else if value.Valid {
ar.ForceApprovalPrompt = value.Bool
_m.ForceApprovalPrompt = value.Bool
}
case authrequest.FieldLoggedIn:
if value, ok := values[i].(*sql.NullBool); !ok {
return fmt.Errorf("unexpected type %T for field logged_in", values[i])
} else if value.Valid {
ar.LoggedIn = value.Bool
_m.LoggedIn = value.Bool
}
case authrequest.FieldClaimsUserID:
if value, ok := values[i].(*sql.NullString); !ok {
return fmt.Errorf("unexpected type %T for field claims_user_id", values[i])
} else if value.Valid {
ar.ClaimsUserID = value.String
_m.ClaimsUserID = value.String
}
case authrequest.FieldClaimsUsername:
if value, ok := values[i].(*sql.NullString); !ok {
return fmt.Errorf("unexpected type %T for field claims_username", values[i])
} else if value.Valid {
ar.ClaimsUsername = value.String
_m.ClaimsUsername = value.String
}
case authrequest.FieldClaimsEmail:
if value, ok := values[i].(*sql.NullString); !ok {
return fmt.Errorf("unexpected type %T for field claims_email", values[i])
} else if value.Valid {
ar.ClaimsEmail = value.String
_m.ClaimsEmail = value.String
}
case authrequest.FieldClaimsEmailVerified:
if value, ok := values[i].(*sql.NullBool); !ok {
return fmt.Errorf("unexpected type %T for field claims_email_verified", values[i])
} else if value.Valid {
ar.ClaimsEmailVerified = value.Bool
_m.ClaimsEmailVerified = value.Bool
}
case authrequest.FieldClaimsGroups:
if value, ok := values[i].(*[]byte); !ok {
return fmt.Errorf("unexpected type %T for field claims_groups", values[i])
} else if value != nil && len(*value) > 0 {
if err := json.Unmarshal(*value, &ar.ClaimsGroups); err != nil {
if err := json.Unmarshal(*value, &_m.ClaimsGroups); err != nil {
return fmt.Errorf("unmarshal field claims_groups: %w", err)
}
}
@@ -183,46 +183,46 @@ func (ar *AuthRequest) assignValues(columns []string, values []any) error {
if value, ok := values[i].(*sql.NullString); !ok {
return fmt.Errorf("unexpected type %T for field claims_preferred_username", values[i])
} else if value.Valid {
ar.ClaimsPreferredUsername = value.String
_m.ClaimsPreferredUsername = value.String
}
case authrequest.FieldConnectorID:
if value, ok := values[i].(*sql.NullString); !ok {
return fmt.Errorf("unexpected type %T for field connector_id", values[i])
} else if value.Valid {
ar.ConnectorID = value.String
_m.ConnectorID = value.String
}
case authrequest.FieldConnectorData:
if value, ok := values[i].(*[]byte); !ok {
return fmt.Errorf("unexpected type %T for field connector_data", values[i])
} else if value != nil {
ar.ConnectorData = value
_m.ConnectorData = value
}
case authrequest.FieldExpiry:
if value, ok := values[i].(*sql.NullTime); !ok {
return fmt.Errorf("unexpected type %T for field expiry", values[i])
} else if value.Valid {
ar.Expiry = value.Time
_m.Expiry = value.Time
}
case authrequest.FieldCodeChallenge:
if value, ok := values[i].(*sql.NullString); !ok {
return fmt.Errorf("unexpected type %T for field code_challenge", values[i])
} else if value.Valid {
ar.CodeChallenge = value.String
_m.CodeChallenge = value.String
}
case authrequest.FieldCodeChallengeMethod:
if value, ok := values[i].(*sql.NullString); !ok {
return fmt.Errorf("unexpected type %T for field code_challenge_method", values[i])
} else if value.Valid {
ar.CodeChallengeMethod = value.String
_m.CodeChallengeMethod = value.String
}
case authrequest.FieldHmacKey:
if value, ok := values[i].(*[]byte); !ok {
return fmt.Errorf("unexpected type %T for field hmac_key", values[i])
} else if value != nil {
ar.HmacKey = *value
_m.HmacKey = *value
}
default:
ar.selectValues.Set(columns[i], values[i])
_m.selectValues.Set(columns[i], values[i])
}
}
return nil
@@ -230,94 +230,94 @@ func (ar *AuthRequest) assignValues(columns []string, values []any) error {
// Value returns the ent.Value that was dynamically selected and assigned to the AuthRequest.
// This includes values selected through modifiers, order, etc.
func (ar *AuthRequest) Value(name string) (ent.Value, error) {
return ar.selectValues.Get(name)
func (_m *AuthRequest) Value(name string) (ent.Value, error) {
return _m.selectValues.Get(name)
}
// Update returns a builder for updating this AuthRequest.
// Note that you need to call AuthRequest.Unwrap() before calling this method if this AuthRequest
// was returned from a transaction, and the transaction was committed or rolled back.
func (ar *AuthRequest) Update() *AuthRequestUpdateOne {
return NewAuthRequestClient(ar.config).UpdateOne(ar)
func (_m *AuthRequest) Update() *AuthRequestUpdateOne {
return NewAuthRequestClient(_m.config).UpdateOne(_m)
}
// Unwrap unwraps the AuthRequest entity that was returned from a transaction after it was closed,
// so that all future queries will be executed through the driver which created the transaction.
func (ar *AuthRequest) Unwrap() *AuthRequest {
_tx, ok := ar.config.driver.(*txDriver)
func (_m *AuthRequest) Unwrap() *AuthRequest {
_tx, ok := _m.config.driver.(*txDriver)
if !ok {
panic("db: AuthRequest is not a transactional entity")
}
ar.config.driver = _tx.drv
return ar
_m.config.driver = _tx.drv
return _m
}
// String implements the fmt.Stringer.
func (ar *AuthRequest) String() string {
func (_m *AuthRequest) String() string {
var builder strings.Builder
builder.WriteString("AuthRequest(")
builder.WriteString(fmt.Sprintf("id=%v, ", ar.ID))
builder.WriteString(fmt.Sprintf("id=%v, ", _m.ID))
builder.WriteString("client_id=")
builder.WriteString(ar.ClientID)
builder.WriteString(_m.ClientID)
builder.WriteString(", ")
builder.WriteString("scopes=")
builder.WriteString(fmt.Sprintf("%v", ar.Scopes))
builder.WriteString(fmt.Sprintf("%v", _m.Scopes))
builder.WriteString(", ")
builder.WriteString("response_types=")
builder.WriteString(fmt.Sprintf("%v", ar.ResponseTypes))
builder.WriteString(fmt.Sprintf("%v", _m.ResponseTypes))
builder.WriteString(", ")
builder.WriteString("redirect_uri=")
builder.WriteString(ar.RedirectURI)
builder.WriteString(_m.RedirectURI)
builder.WriteString(", ")
builder.WriteString("nonce=")
builder.WriteString(ar.Nonce)
builder.WriteString(_m.Nonce)
builder.WriteString(", ")
builder.WriteString("state=")
builder.WriteString(ar.State)
builder.WriteString(_m.State)
builder.WriteString(", ")
builder.WriteString("force_approval_prompt=")
builder.WriteString(fmt.Sprintf("%v", ar.ForceApprovalPrompt))
builder.WriteString(fmt.Sprintf("%v", _m.ForceApprovalPrompt))
builder.WriteString(", ")
builder.WriteString("logged_in=")
builder.WriteString(fmt.Sprintf("%v", ar.LoggedIn))
builder.WriteString(fmt.Sprintf("%v", _m.LoggedIn))
builder.WriteString(", ")
builder.WriteString("claims_user_id=")
builder.WriteString(ar.ClaimsUserID)
builder.WriteString(_m.ClaimsUserID)
builder.WriteString(", ")
builder.WriteString("claims_username=")
builder.WriteString(ar.ClaimsUsername)
builder.WriteString(_m.ClaimsUsername)
builder.WriteString(", ")
builder.WriteString("claims_email=")
builder.WriteString(ar.ClaimsEmail)
builder.WriteString(_m.ClaimsEmail)
builder.WriteString(", ")
builder.WriteString("claims_email_verified=")
builder.WriteString(fmt.Sprintf("%v", ar.ClaimsEmailVerified))
builder.WriteString(fmt.Sprintf("%v", _m.ClaimsEmailVerified))
builder.WriteString(", ")
builder.WriteString("claims_groups=")
builder.WriteString(fmt.Sprintf("%v", ar.ClaimsGroups))
builder.WriteString(fmt.Sprintf("%v", _m.ClaimsGroups))
builder.WriteString(", ")
builder.WriteString("claims_preferred_username=")
builder.WriteString(ar.ClaimsPreferredUsername)
builder.WriteString(_m.ClaimsPreferredUsername)
builder.WriteString(", ")
builder.WriteString("connector_id=")
builder.WriteString(ar.ConnectorID)
builder.WriteString(_m.ConnectorID)
builder.WriteString(", ")
if v := ar.ConnectorData; v != nil {
if v := _m.ConnectorData; v != nil {
builder.WriteString("connector_data=")
builder.WriteString(fmt.Sprintf("%v", *v))
}
builder.WriteString(", ")
builder.WriteString("expiry=")
builder.WriteString(ar.Expiry.Format(time.ANSIC))
builder.WriteString(_m.Expiry.Format(time.ANSIC))
builder.WriteString(", ")
builder.WriteString("code_challenge=")
builder.WriteString(ar.CodeChallenge)
builder.WriteString(_m.CodeChallenge)
builder.WriteString(", ")
builder.WriteString("code_challenge_method=")
builder.WriteString(ar.CodeChallengeMethod)
builder.WriteString(_m.CodeChallengeMethod)
builder.WriteString(", ")
builder.WriteString("hmac_key=")
builder.WriteString(fmt.Sprintf("%v", ar.HmacKey))
builder.WriteString(fmt.Sprintf("%v", _m.HmacKey))
builder.WriteByte(')')
return builder.String()
}
storage/ent/db/authrequest_create.go
+157 -157
View File
File diff suppressed because it is too large Load Diff
storage/ent/db/authrequest_delete.go
+19 -19
View File
@@ -20,56 +20,56 @@ type AuthRequestDelete struct {
}
// Where appends a list predicates to the AuthRequestDelete builder.
func (ard *AuthRequestDelete) Where(ps ...predicate.AuthRequest) *AuthRequestDelete {
ard.mutation.Where(ps...)
return ard
func (_d *AuthRequestDelete) Where(ps ...predicate.AuthRequest) *AuthRequestDelete {
_d.mutation.Where(ps...)
return _d
}
// Exec executes the deletion query and returns how many vertices were deleted.
func (ard *AuthRequestDelete) Exec(ctx context.Context) (int, error) {
return withHooks(ctx, ard.sqlExec, ard.mutation, ard.hooks)
func (_d *AuthRequestDelete) Exec(ctx context.Context) (int, error) {
return withHooks(ctx, _d.sqlExec, _d.mutation, _d.hooks)
}
// ExecX is like Exec, but panics if an error occurs.
func (ard *AuthRequestDelete) ExecX(ctx context.Context) int {
n, err := ard.Exec(ctx)
func (_d *AuthRequestDelete) ExecX(ctx context.Context) int {
n, err := _d.Exec(ctx)
if err != nil {
panic(err)
}
return n
}
func (ard *AuthRequestDelete) sqlExec(ctx context.Context) (int, error) {
func (_d *AuthRequestDelete) sqlExec(ctx context.Context) (int, error) {
_spec := sqlgraph.NewDeleteSpec(authrequest.Table, sqlgraph.NewFieldSpec(authrequest.FieldID, field.TypeString))
if ps := ard.mutation.predicates; len(ps) > 0 {
if ps := _d.mutation.predicates; len(ps) > 0 {
_spec.Predicate = func(selector *sql.Selector) {
for i := range ps {
ps[i](selector)
}
}
}
affected, err := sqlgraph.DeleteNodes(ctx, ard.driver, _spec)
affected, err := sqlgraph.DeleteNodes(ctx, _d.driver, _spec)
if err != nil && sqlgraph.IsConstraintError(err) {
err = &ConstraintError{msg: err.Error(), wrap: err}
}
ard.mutation.done = true
_d.mutation.done = true
return affected, err
}
// AuthRequestDeleteOne is the builder for deleting a single AuthRequest entity.
type AuthRequestDeleteOne struct {
ard *AuthRequestDelete
_d *AuthRequestDelete
}
// Where appends a list predicates to the AuthRequestDelete builder.
func (ardo *AuthRequestDeleteOne) Where(ps ...predicate.AuthRequest) *AuthRequestDeleteOne {
ardo.ard.mutation.Where(ps...)
return ardo
func (_d *AuthRequestDeleteOne) Where(ps ...predicate.AuthRequest) *AuthRequestDeleteOne {
_d._d.mutation.Where(ps...)
return _d
}
// Exec executes the deletion query.
func (ardo *AuthRequestDeleteOne) Exec(ctx context.Context) error {
n, err := ardo.ard.Exec(ctx)
func (_d *AuthRequestDeleteOne) Exec(ctx context.Context) error {
n, err := _d._d.Exec(ctx)
switch {
case err != nil:
return err
@@ -81,8 +81,8 @@ func (ardo *AuthRequestDeleteOne) Exec(ctx context.Context) error {
}
// ExecX is like Exec, but panics if an error occurs.
func (ardo *AuthRequestDeleteOne) ExecX(ctx context.Context) {
if err := ardo.Exec(ctx); err != nil {
func (_d *AuthRequestDeleteOne) ExecX(ctx context.Context) {
if err := _d.Exec(ctx); err != nil {
panic(err)
}
}
storage/ent/db/authrequest_query.go
+136 -136
View File
File diff suppressed because it is too large Load Diff
storage/ent/db/authrequest_update.go
+383 -383
View File
File diff suppressed because it is too large Load Diff
storage/ent/db/client.go
+40 -40
View File
@@ -333,8 +333,8 @@ func (c *AuthCodeClient) Update() *AuthCodeUpdate {
}
// UpdateOne returns an update builder for the given entity.
func (c *AuthCodeClient) UpdateOne(ac *AuthCode) *AuthCodeUpdateOne {
mutation := newAuthCodeMutation(c.config, OpUpdateOne, withAuthCode(ac))
func (c *AuthCodeClient) UpdateOne(_m *AuthCode) *AuthCodeUpdateOne {
mutation := newAuthCodeMutation(c.config, OpUpdateOne, withAuthCode(_m))
return &AuthCodeUpdateOne{config: c.config, hooks: c.Hooks(), mutation: mutation}
}
@@ -351,8 +351,8 @@ func (c *AuthCodeClient) Delete() *AuthCodeDelete {
}
// DeleteOne returns a builder for deleting the given entity.
func (c *AuthCodeClient) DeleteOne(ac *AuthCode) *AuthCodeDeleteOne {
return c.DeleteOneID(ac.ID)
func (c *AuthCodeClient) DeleteOne(_m *AuthCode) *AuthCodeDeleteOne {
return c.DeleteOneID(_m.ID)
}
// DeleteOneID returns a builder for deleting the given entity by its id.
@@ -466,8 +466,8 @@ func (c *AuthRequestClient) Update() *AuthRequestUpdate {
}
// UpdateOne returns an update builder for the given entity.
func (c *AuthRequestClient) UpdateOne(ar *AuthRequest) *AuthRequestUpdateOne {
mutation := newAuthRequestMutation(c.config, OpUpdateOne, withAuthRequest(ar))
func (c *AuthRequestClient) UpdateOne(_m *AuthRequest) *AuthRequestUpdateOne {
mutation := newAuthRequestMutation(c.config, OpUpdateOne, withAuthRequest(_m))
return &AuthRequestUpdateOne{config: c.config, hooks: c.Hooks(), mutation: mutation}
}
@@ -484,8 +484,8 @@ func (c *AuthRequestClient) Delete() *AuthRequestDelete {
}
// DeleteOne returns a builder for deleting the given entity.
func (c *AuthRequestClient) DeleteOne(ar *AuthRequest) *AuthRequestDeleteOne {
return c.DeleteOneID(ar.ID)
func (c *AuthRequestClient) DeleteOne(_m *AuthRequest) *AuthRequestDeleteOne {
return c.DeleteOneID(_m.ID)
}
// DeleteOneID returns a builder for deleting the given entity by its id.
@@ -599,8 +599,8 @@ func (c *ConnectorClient) Update() *ConnectorUpdate {
}
// UpdateOne returns an update builder for the given entity.
func (c *ConnectorClient) UpdateOne(co *Connector) *ConnectorUpdateOne {
mutation := newConnectorMutation(c.config, OpUpdateOne, withConnector(co))
func (c *ConnectorClient) UpdateOne(_m *Connector) *ConnectorUpdateOne {
mutation := newConnectorMutation(c.config, OpUpdateOne, withConnector(_m))
return &ConnectorUpdateOne{config: c.config, hooks: c.Hooks(), mutation: mutation}
}
@@ -617,8 +617,8 @@ func (c *ConnectorClient) Delete() *ConnectorDelete {
}
// DeleteOne returns a builder for deleting the given entity.
func (c *ConnectorClient) DeleteOne(co *Connector) *ConnectorDeleteOne {
return c.DeleteOneID(co.ID)
func (c *ConnectorClient) DeleteOne(_m *Connector) *ConnectorDeleteOne {
return c.DeleteOneID(_m.ID)
}
// DeleteOneID returns a builder for deleting the given entity by its id.
@@ -732,8 +732,8 @@ func (c *DeviceRequestClient) Update() *DeviceRequestUpdate {
}
// UpdateOne returns an update builder for the given entity.
func (c *DeviceRequestClient) UpdateOne(dr *DeviceRequest) *DeviceRequestUpdateOne {
mutation := newDeviceRequestMutation(c.config, OpUpdateOne, withDeviceRequest(dr))
func (c *DeviceRequestClient) UpdateOne(_m *DeviceRequest) *DeviceRequestUpdateOne {
mutation := newDeviceRequestMutation(c.config, OpUpdateOne, withDeviceRequest(_m))
return &DeviceRequestUpdateOne{config: c.config, hooks: c.Hooks(), mutation: mutation}
}
@@ -750,8 +750,8 @@ func (c *DeviceRequestClient) Delete() *DeviceRequestDelete {
}
// DeleteOne returns a builder for deleting the given entity.
func (c *DeviceRequestClient) DeleteOne(dr *DeviceRequest) *DeviceRequestDeleteOne {
return c.DeleteOneID(dr.ID)
func (c *DeviceRequestClient) DeleteOne(_m *DeviceRequest) *DeviceRequestDeleteOne {
return c.DeleteOneID(_m.ID)
}
// DeleteOneID returns a builder for deleting the given entity by its id.
@@ -865,8 +865,8 @@ func (c *DeviceTokenClient) Update() *DeviceTokenUpdate {
}
// UpdateOne returns an update builder for the given entity.
func (c *DeviceTokenClient) UpdateOne(dt *DeviceToken) *DeviceTokenUpdateOne {
mutation := newDeviceTokenMutation(c.config, OpUpdateOne, withDeviceToken(dt))
func (c *DeviceTokenClient) UpdateOne(_m *DeviceToken) *DeviceTokenUpdateOne {
mutation := newDeviceTokenMutation(c.config, OpUpdateOne, withDeviceToken(_m))
return &DeviceTokenUpdateOne{config: c.config, hooks: c.Hooks(), mutation: mutation}
}
@@ -883,8 +883,8 @@ func (c *DeviceTokenClient) Delete() *DeviceTokenDelete {
}
// DeleteOne returns a builder for deleting the given entity.
func (c *DeviceTokenClient) DeleteOne(dt *DeviceToken) *DeviceTokenDeleteOne {
return c.DeleteOneID(dt.ID)
func (c *DeviceTokenClient) DeleteOne(_m *DeviceToken) *DeviceTokenDeleteOne {
return c.DeleteOneID(_m.ID)
}
// DeleteOneID returns a builder for deleting the given entity by its id.
@@ -998,8 +998,8 @@ func (c *KeysClient) Update() *KeysUpdate {
}
// UpdateOne returns an update builder for the given entity.
func (c *KeysClient) UpdateOne(k *Keys) *KeysUpdateOne {
mutation := newKeysMutation(c.config, OpUpdateOne, withKeys(k))
func (c *KeysClient) UpdateOne(_m *Keys) *KeysUpdateOne {
mutation := newKeysMutation(c.config, OpUpdateOne, withKeys(_m))
return &KeysUpdateOne{config: c.config, hooks: c.Hooks(), mutation: mutation}
}
@@ -1016,8 +1016,8 @@ func (c *KeysClient) Delete() *KeysDelete {
}
// DeleteOne returns a builder for deleting the given entity.
func (c *KeysClient) DeleteOne(k *Keys) *KeysDeleteOne {
return c.DeleteOneID(k.ID)
func (c *KeysClient) DeleteOne(_m *Keys) *KeysDeleteOne {
return c.DeleteOneID(_m.ID)
}
// DeleteOneID returns a builder for deleting the given entity by its id.
@@ -1131,8 +1131,8 @@ func (c *OAuth2ClientClient) Update() *OAuth2ClientUpdate {
}
// UpdateOne returns an update builder for the given entity.
func (c *OAuth2ClientClient) UpdateOne(o *OAuth2Client) *OAuth2ClientUpdateOne {
mutation := newOAuth2ClientMutation(c.config, OpUpdateOne, withOAuth2Client(o))
func (c *OAuth2ClientClient) UpdateOne(_m *OAuth2Client) *OAuth2ClientUpdateOne {
mutation := newOAuth2ClientMutation(c.config, OpUpdateOne, withOAuth2Client(_m))
return &OAuth2ClientUpdateOne{config: c.config, hooks: c.Hooks(), mutation: mutation}
}
@@ -1149,8 +1149,8 @@ func (c *OAuth2ClientClient) Delete() *OAuth2ClientDelete {
}
// DeleteOne returns a builder for deleting the given entity.
func (c *OAuth2ClientClient) DeleteOne(o *OAuth2Client) *OAuth2ClientDeleteOne {
return c.DeleteOneID(o.ID)
func (c *OAuth2ClientClient) DeleteOne(_m *OAuth2Client) *OAuth2ClientDeleteOne {
return c.DeleteOneID(_m.ID)
}
// DeleteOneID returns a builder for deleting the given entity by its id.
@@ -1264,8 +1264,8 @@ func (c *OfflineSessionClient) Update() *OfflineSessionUpdate {
}
// UpdateOne returns an update builder for the given entity.
func (c *OfflineSessionClient) UpdateOne(os *OfflineSession) *OfflineSessionUpdateOne {
mutation := newOfflineSessionMutation(c.config, OpUpdateOne, withOfflineSession(os))
func (c *OfflineSessionClient) UpdateOne(_m *OfflineSession) *OfflineSessionUpdateOne {
mutation := newOfflineSessionMutation(c.config, OpUpdateOne, withOfflineSession(_m))
return &OfflineSessionUpdateOne{config: c.config, hooks: c.Hooks(), mutation: mutation}
}
@@ -1282,8 +1282,8 @@ func (c *OfflineSessionClient) Delete() *OfflineSessionDelete {
}
// DeleteOne returns a builder for deleting the given entity.
func (c *OfflineSessionClient) DeleteOne(os *OfflineSession) *OfflineSessionDeleteOne {
return c.DeleteOneID(os.ID)
func (c *OfflineSessionClient) DeleteOne(_m *OfflineSession) *OfflineSessionDeleteOne {
return c.DeleteOneID(_m.ID)
}
// DeleteOneID returns a builder for deleting the given entity by its id.
@@ -1397,8 +1397,8 @@ func (c *PasswordClient) Update() *PasswordUpdate {
}
// UpdateOne returns an update builder for the given entity.
func (c *PasswordClient) UpdateOne(pa *Password) *PasswordUpdateOne {
mutation := newPasswordMutation(c.config, OpUpdateOne, withPassword(pa))
func (c *PasswordClient) UpdateOne(_m *Password) *PasswordUpdateOne {
mutation := newPasswordMutation(c.config, OpUpdateOne, withPassword(_m))
return &PasswordUpdateOne{config: c.config, hooks: c.Hooks(), mutation: mutation}
}
@@ -1415,8 +1415,8 @@ func (c *PasswordClient) Delete() *PasswordDelete {
}
// DeleteOne returns a builder for deleting the given entity.
func (c *PasswordClient) DeleteOne(pa *Password) *PasswordDeleteOne {
return c.DeleteOneID(pa.ID)
func (c *PasswordClient) DeleteOne(_m *Password) *PasswordDeleteOne {
return c.DeleteOneID(_m.ID)
}
// DeleteOneID returns a builder for deleting the given entity by its id.
@@ -1530,8 +1530,8 @@ func (c *RefreshTokenClient) Update() *RefreshTokenUpdate {
}
// UpdateOne returns an update builder for the given entity.
func (c *RefreshTokenClient) UpdateOne(rt *RefreshToken) *RefreshTokenUpdateOne {
mutation := newRefreshTokenMutation(c.config, OpUpdateOne, withRefreshToken(rt))
func (c *RefreshTokenClient) UpdateOne(_m *RefreshToken) *RefreshTokenUpdateOne {
mutation := newRefreshTokenMutation(c.config, OpUpdateOne, withRefreshToken(_m))
return &RefreshTokenUpdateOne{config: c.config, hooks: c.Hooks(), mutation: mutation}
}
@@ -1548,8 +1548,8 @@ func (c *RefreshTokenClient) Delete() *RefreshTokenDelete {
}
// DeleteOne returns a builder for deleting the given entity.
func (c *RefreshTokenClient) DeleteOne(rt *RefreshToken) *RefreshTokenDeleteOne {
return c.DeleteOneID(rt.ID)
func (c *RefreshTokenClient) DeleteOne(_m *RefreshToken) *RefreshTokenDeleteOne {
return c.DeleteOneID(_m.ID)
}
// DeleteOneID returns a builder for deleting the given entity by its id.
storage/ent/db/connector.go
+21 -21
View File
@@ -45,7 +45,7 @@ func (*Connector) scanValues(columns []string) ([]any, error) {
// assignValues assigns the values that were returned from sql.Rows (after scanning)
// to the Connector fields.
func (c *Connector) assignValues(columns []string, values []any) error {
func (_m *Connector) assignValues(columns []string, values []any) error {
if m, n := len(values), len(columns); m < n {
return fmt.Errorf("mismatch number of scan values: %d != %d", m, n)
}
@@ -55,34 +55,34 @@ func (c *Connector) assignValues(columns []string, values []any) error {
if value, ok := values[i].(*sql.NullString); !ok {
return fmt.Errorf("unexpected type %T for field id", values[i])
} else if value.Valid {
c.ID = value.String
_m.ID = value.String
}
case connector.FieldType:
if value, ok := values[i].(*sql.NullString); !ok {
return fmt.Errorf("unexpected type %T for field type", values[i])
} else if value.Valid {
c.Type = value.String
_m.Type = value.String
}
case connector.FieldName:
if value, ok := values[i].(*sql.NullString); !ok {
return fmt.Errorf("unexpected type %T for field name", values[i])
} else if value.Valid {
c.Name = value.String
_m.Name = value.String
}
case connector.FieldResourceVersion:
if value, ok := values[i].(*sql.NullString); !ok {
return fmt.Errorf("unexpected type %T for field resource_version", values[i])
} else if value.Valid {
c.ResourceVersion = value.String
_m.ResourceVersion = value.String
}
case connector.FieldConfig:
if value, ok := values[i].(*[]byte); !ok {
return fmt.Errorf("unexpected type %T for field config", values[i])
} else if value != nil {
c.Config = *value
_m.Config = *value
}
default:
c.selectValues.Set(columns[i], values[i])
_m.selectValues.Set(columns[i], values[i])
}
}
return nil
@@ -90,44 +90,44 @@ func (c *Connector) assignValues(columns []string, values []any) error {
// Value returns the ent.Value that was dynamically selected and assigned to the Connector.
// This includes values selected through modifiers, order, etc.
func (c *Connector) Value(name string) (ent.Value, error) {
return c.selectValues.Get(name)
func (_m *Connector) Value(name string) (ent.Value, error) {
return _m.selectValues.Get(name)
}
// Update returns a builder for updating this Connector.
// Note that you need to call Connector.Unwrap() before calling this method if this Connector
// was returned from a transaction, and the transaction was committed or rolled back.
func (c *Connector) Update() *ConnectorUpdateOne {
return NewConnectorClient(c.config).UpdateOne(c)
func (_m *Connector) Update() *ConnectorUpdateOne {
return NewConnectorClient(_m.config).UpdateOne(_m)
}
// Unwrap unwraps the Connector entity that was returned from a transaction after it was closed,
// so that all future queries will be executed through the driver which created the transaction.
func (c *Connector) Unwrap() *Connector {
_tx, ok := c.config.driver.(*txDriver)
func (_m *Connector) Unwrap() *Connector {
_tx, ok := _m.config.driver.(*txDriver)
if !ok {
panic("db: Connector is not a transactional entity")
}
c.config.driver = _tx.drv
return c
_m.config.driver = _tx.drv
return _m
}
// String implements the fmt.Stringer.
func (c *Connector) String() string {
func (_m *Connector) String() string {
var builder strings.Builder
builder.WriteString("Connector(")
builder.WriteString(fmt.Sprintf("id=%v, ", c.ID))
builder.WriteString(fmt.Sprintf("id=%v, ", _m.ID))
builder.WriteString("type=")
builder.WriteString(c.Type)
builder.WriteString(_m.Type)
builder.WriteString(", ")
builder.WriteString("name=")
builder.WriteString(c.Name)
builder.WriteString(_m.Name)
builder.WriteString(", ")
builder.WriteString("resource_version=")
builder.WriteString(c.ResourceVersion)
builder.WriteString(_m.ResourceVersion)
builder.WriteString(", ")
builder.WriteString("config=")
builder.WriteString(fmt.Sprintf("%v", c.Config))
builder.WriteString(fmt.Sprintf("%v", _m.Config))
builder.WriteByte(')')
return builder.String()
}
storage/ent/db/connector_create.go
+63 -63
View File
@@ -20,48 +20,48 @@ type ConnectorCreate struct {
}
// SetType sets the "type" field.
func (cc *ConnectorCreate) SetType(s string) *ConnectorCreate {
cc.mutation.SetType(s)
return cc
func (_c *ConnectorCreate) SetType(v string) *ConnectorCreate {
_c.mutation.SetType(v)
return _c
}
// SetName sets the "name" field.
func (cc *ConnectorCreate) SetName(s string) *ConnectorCreate {
cc.mutation.SetName(s)
return cc
func (_c *ConnectorCreate) SetName(v string) *ConnectorCreate {
_c.mutation.SetName(v)
return _c
}
// SetResourceVersion sets the "resource_version" field.
func (cc *ConnectorCreate) SetResourceVersion(s string) *ConnectorCreate {
cc.mutation.SetResourceVersion(s)
return cc
func (_c *ConnectorCreate) SetResourceVersion(v string) *ConnectorCreate {
_c.mutation.SetResourceVersion(v)
return _c
}
// SetConfig sets the "config" field.
func (cc *ConnectorCreate) SetConfig(b []byte) *ConnectorCreate {
cc.mutation.SetConfig(b)
return cc
func (_c *ConnectorCreate) SetConfig(v []byte) *ConnectorCreate {
_c.mutation.SetConfig(v)
return _c
}
// SetID sets the "id" field.
func (cc *ConnectorCreate) SetID(s string) *ConnectorCreate {
cc.mutation.SetID(s)
return cc
func (_c *ConnectorCreate) SetID(v string) *ConnectorCreate {
_c.mutation.SetID(v)
return _c
}
// Mutation returns the ConnectorMutation object of the builder.
func (cc *ConnectorCreate) Mutation() *ConnectorMutation {
return cc.mutation
func (_c *ConnectorCreate) Mutation() *ConnectorMutation {
return _c.mutation
}
// Save creates the Connector in the database.
func (cc *ConnectorCreate) Save(ctx context.Context) (*Connector, error) {
return withHooks(ctx, cc.sqlSave, cc.mutation, cc.hooks)
func (_c *ConnectorCreate) Save(ctx context.Context) (*Connector, error) {
return withHooks(ctx, _c.sqlSave, _c.mutation, _c.hooks)
}
// SaveX calls Save and panics if Save returns an error.
func (cc *ConnectorCreate) SaveX(ctx context.Context) *Connector {
v, err := cc.Save(ctx)
func (_c *ConnectorCreate) SaveX(ctx context.Context) *Connector {
v, err := _c.Save(ctx)
if err != nil {
panic(err)
}
@@ -69,43 +69,43 @@ func (cc *ConnectorCreate) SaveX(ctx context.Context) *Connector {
}
// Exec executes the query.
func (cc *ConnectorCreate) Exec(ctx context.Context) error {
_, err := cc.Save(ctx)
func (_c *ConnectorCreate) Exec(ctx context.Context) error {
_, err := _c.Save(ctx)
return err
}
// ExecX is like Exec, but panics if an error occurs.
func (cc *ConnectorCreate) ExecX(ctx context.Context) {
if err := cc.Exec(ctx); err != nil {
func (_c *ConnectorCreate) ExecX(ctx context.Context) {
if err := _c.Exec(ctx); err != nil {
panic(err)
}
}
// check runs all checks and user-defined validators on the builder.
func (cc *ConnectorCreate) check() error {
if _, ok := cc.mutation.GetType(); !ok {
func (_c *ConnectorCreate) check() error {
if _, ok := _c.mutation.GetType(); !ok {
return &ValidationError{Name: "type", err: errors.New(`db: missing required field "Connector.type"`)}
}
if v, ok := cc.mutation.GetType(); ok {
if v, ok := _c.mutation.GetType(); ok {
if err := connector.TypeValidator(v); err != nil {
return &ValidationError{Name: "type", err: fmt.Errorf(`db: validator failed for field "Connector.type": %w`, err)}
}
}
if _, ok := cc.mutation.Name(); !ok {
if _, ok := _c.mutation.Name(); !ok {
return &ValidationError{Name: "name", err: errors.New(`db: missing required field "Connector.name"`)}
}
if v, ok := cc.mutation.Name(); ok {
if v, ok := _c.mutation.Name(); ok {
if err := connector.NameValidator(v); err != nil {
return &ValidationError{Name: "name", err: fmt.Errorf(`db: validator failed for field "Connector.name": %w`, err)}
}
}
if _, ok := cc.mutation.ResourceVersion(); !ok {
if _, ok := _c.mutation.ResourceVersion(); !ok {
return &ValidationError{Name: "resource_version", err: errors.New(`db: missing required field "Connector.resource_version"`)}
}
if _, ok := cc.mutation.Config(); !ok {
if _, ok := _c.mutation.Config(); !ok {
return &ValidationError{Name: "config", err: errors.New(`db: missing required field "Connector.config"`)}
}
if v, ok := cc.mutation.ID(); ok {
if v, ok := _c.mutation.ID(); ok {
if err := connector.IDValidator(v); err != nil {
return &ValidationError{Name: "id", err: fmt.Errorf(`db: validator failed for field "Connector.id": %w`, err)}
}
@@ -113,12 +113,12 @@ func (cc *ConnectorCreate) check() error {
return nil
}
func (cc *ConnectorCreate) sqlSave(ctx context.Context) (*Connector, error) {
if err := cc.check(); err != nil {
func (_c *ConnectorCreate) sqlSave(ctx context.Context) (*Connector, error) {
if err := _c.check(); err != nil {
return nil, err
}
_node, _spec := cc.createSpec()
if err := sqlgraph.CreateNode(ctx, cc.driver, _spec); err != nil {
_node, _spec := _c.createSpec()
if err := sqlgraph.CreateNode(ctx, _c.driver, _spec); err != nil {
if sqlgraph.IsConstraintError(err) {
err = &ConstraintError{msg: err.Error(), wrap: err}
}
@@ -131,33 +131,33 @@ func (cc *ConnectorCreate) sqlSave(ctx context.Context) (*Connector, error) {
return nil, fmt.Errorf("unexpected Connector.ID type: %T", _spec.ID.Value)
}
}
cc.mutation.id = &_node.ID
cc.mutation.done = true
_c.mutation.id = &_node.ID
_c.mutation.done = true
return _node, nil
}
func (cc *ConnectorCreate) createSpec() (*Connector, *sqlgraph.CreateSpec) {
func (_c *ConnectorCreate) createSpec() (*Connector, *sqlgraph.CreateSpec) {
var (
_node = &Connector{config: cc.config}
_node = &Connector{config: _c.config}
_spec = sqlgraph.NewCreateSpec(connector.Table, sqlgraph.NewFieldSpec(connector.FieldID, field.TypeString))
)
if id, ok := cc.mutation.ID(); ok {
if id, ok := _c.mutation.ID(); ok {
_node.ID = id
_spec.ID.Value = id
}
if value, ok := cc.mutation.GetType(); ok {
if value, ok := _c.mutation.GetType(); ok {
_spec.SetField(connector.FieldType, field.TypeString, value)
_node.Type = value
}
if value, ok := cc.mutation.Name(); ok {
if value, ok := _c.mutation.Name(); ok {
_spec.SetField(connector.FieldName, field.TypeString, value)
_node.Name = value
}
if value, ok := cc.mutation.ResourceVersion(); ok {
if value, ok := _c.mutation.ResourceVersion(); ok {
_spec.SetField(connector.FieldResourceVersion, field.TypeString, value)
_node.ResourceVersion = value
}
if value, ok := cc.mutation.Config(); ok {
if value, ok := _c.mutation.Config(); ok {
_spec.SetField(connector.FieldConfig, field.TypeBytes, value)
_node.Config = value
}
@@ -172,16 +172,16 @@ type ConnectorCreateBulk struct {
}
// Save creates the Connector entities in the database.
func (ccb *ConnectorCreateBulk) Save(ctx context.Context) ([]*Connector, error) {
if ccb.err != nil {
return nil, ccb.err
func (_c *ConnectorCreateBulk) Save(ctx context.Context) ([]*Connector, error) {
if _c.err != nil {
return nil, _c.err
}
specs := make([]*sqlgraph.CreateSpec, len(ccb.builders))
nodes := make([]*Connector, len(ccb.builders))
mutators := make([]Mutator, len(ccb.builders))
for i := range ccb.builders {
specs := make([]*sqlgraph.CreateSpec, len(_c.builders))
nodes := make([]*Connector, len(_c.builders))
mutators := make([]Mutator, len(_c.builders))
for i := range _c.builders {
func(i int, root context.Context) {
builder := ccb.builders[i]
builder := _c.builders[i]
var mut Mutator = MutateFunc(func(ctx context.Context, m Mutation) (Value, error) {
mutation, ok := m.(*ConnectorMutation)
if !ok {
@@ -194,11 +194,11 @@ func (ccb *ConnectorCreateBulk) Save(ctx context.Context) ([]*Connector, error)
var err error
nodes[i], specs[i] = builder.createSpec()
if i < len(mutators)-1 {
_, err = mutators[i+1].Mutate(root, ccb.builders[i+1].mutation)
_, err = mutators[i+1].Mutate(root, _c.builders[i+1].mutation)
} else {
spec := &sqlgraph.BatchCreateSpec{Nodes: specs}
// Invoke the actual operation on the latest mutation in the chain.
if err = sqlgraph.BatchCreate(ctx, ccb.driver, spec); err != nil {
if err = sqlgraph.BatchCreate(ctx, _c.driver, spec); err != nil {
if sqlgraph.IsConstraintError(err) {
err = &ConstraintError{msg: err.Error(), wrap: err}
}
@@ -218,7 +218,7 @@ func (ccb *ConnectorCreateBulk) Save(ctx context.Context) ([]*Connector, error)
}(i, ctx)
}
if len(mutators) > 0 {
if _, err := mutators[0].Mutate(ctx, ccb.builders[0].mutation); err != nil {
if _, err := mutators[0].Mutate(ctx, _c.builders[0].mutation); err != nil {
return nil, err
}
}
@@ -226,8 +226,8 @@ func (ccb *ConnectorCreateBulk) Save(ctx context.Context) ([]*Connector, error)
}
// SaveX is like Save, but panics if an error occurs.
func (ccb *ConnectorCreateBulk) SaveX(ctx context.Context) []*Connector {
v, err := ccb.Save(ctx)
func (_c *ConnectorCreateBulk) SaveX(ctx context.Context) []*Connector {
v, err := _c.Save(ctx)
if err != nil {
panic(err)
}
@@ -235,14 +235,14 @@ func (ccb *ConnectorCreateBulk) SaveX(ctx context.Context) []*Connector {
}
// Exec executes the query.
func (ccb *ConnectorCreateBulk) Exec(ctx context.Context) error {
_, err := ccb.Save(ctx)
func (_c *ConnectorCreateBulk) Exec(ctx context.Context) error {
_, err := _c.Save(ctx)
return err
}
// ExecX is like Exec, but panics if an error occurs.
func (ccb *ConnectorCreateBulk) ExecX(ctx context.Context) {
if err := ccb.Exec(ctx); err != nil {
func (_c *ConnectorCreateBulk) ExecX(ctx context.Context) {
if err := _c.Exec(ctx); err != nil {
panic(err)
}
}
storage/ent/db/connector_delete.go
+19 -19
View File
@@ -20,56 +20,56 @@ type ConnectorDelete struct {
}
// Where appends a list predicates to the ConnectorDelete builder.
func (cd *ConnectorDelete) Where(ps ...predicate.Connector) *ConnectorDelete {
cd.mutation.Where(ps...)
return cd
func (_d *ConnectorDelete) Where(ps ...predicate.Connector) *ConnectorDelete {
_d.mutation.Where(ps...)
return _d
}
// Exec executes the deletion query and returns how many vertices were deleted.
func (cd *ConnectorDelete) Exec(ctx context.Context) (int, error) {
return withHooks(ctx, cd.sqlExec, cd.mutation, cd.hooks)
func (_d *ConnectorDelete) Exec(ctx context.Context) (int, error) {
return withHooks(ctx, _d.sqlExec, _d.mutation, _d.hooks)
}
// ExecX is like Exec, but panics if an error occurs.
func (cd *ConnectorDelete) ExecX(ctx context.Context) int {
n, err := cd.Exec(ctx)
func (_d *ConnectorDelete) ExecX(ctx context.Context) int {
n, err := _d.Exec(ctx)
if err != nil {
panic(err)
}
return n
}
func (cd *ConnectorDelete) sqlExec(ctx context.Context) (int, error) {
func (_d *ConnectorDelete) sqlExec(ctx context.Context) (int, error) {
_spec := sqlgraph.NewDeleteSpec(connector.Table, sqlgraph.NewFieldSpec(connector.FieldID, field.TypeString))
if ps := cd.mutation.predicates; len(ps) > 0 {
if ps := _d.mutation.predicates; len(ps) > 0 {
_spec.Predicate = func(selector *sql.Selector) {
for i := range ps {
ps[i](selector)
}
}
}
affected, err := sqlgraph.DeleteNodes(ctx, cd.driver, _spec)
affected, err := sqlgraph.DeleteNodes(ctx, _d.driver, _spec)
if err != nil && sqlgraph.IsConstraintError(err) {
err = &ConstraintError{msg: err.Error(), wrap: err}
}
cd.mutation.done = true
_d.mutation.done = true
return affected, err
}
// ConnectorDeleteOne is the builder for deleting a single Connector entity.
type ConnectorDeleteOne struct {
cd *ConnectorDelete
_d *ConnectorDelete
}
// Where appends a list predicates to the ConnectorDelete builder.
func (cdo *ConnectorDeleteOne) Where(ps ...predicate.Connector) *ConnectorDeleteOne {
cdo.cd.mutation.Where(ps...)
return cdo
func (_d *ConnectorDeleteOne) Where(ps ...predicate.Connector) *ConnectorDeleteOne {
_d._d.mutation.Where(ps...)
return _d
}
// Exec executes the deletion query.
func (cdo *ConnectorDeleteOne) Exec(ctx context.Context) error {
n, err := cdo.cd.Exec(ctx)
func (_d *ConnectorDeleteOne) Exec(ctx context.Context) error {
n, err := _d._d.Exec(ctx)
switch {
case err != nil:
return err
@@ -81,8 +81,8 @@ func (cdo *ConnectorDeleteOne) Exec(ctx context.Context) error {
}
// ExecX is like Exec, but panics if an error occurs.
func (cdo *ConnectorDeleteOne) ExecX(ctx context.Context) {
if err := cdo.Exec(ctx); err != nil {
func (_d *ConnectorDeleteOne) ExecX(ctx context.Context) {
if err := _d.Exec(ctx); err != nil {
panic(err)
}
}
storage/ent/db/connector_query.go
+136 -136
View File
File diff suppressed because it is too large Load Diff
storage/ent/db/connector_update.go
+106 -106
View File
@@ -22,72 +22,72 @@ type ConnectorUpdate struct {
}
// Where appends a list predicates to the ConnectorUpdate builder.
func (cu *ConnectorUpdate) Where(ps ...predicate.Connector) *ConnectorUpdate {
cu.mutation.Where(ps...)
return cu
func (_u *ConnectorUpdate) Where(ps ...predicate.Connector) *ConnectorUpdate {
_u.mutation.Where(ps...)
return _u
}
// SetType sets the "type" field.
func (cu *ConnectorUpdate) SetType(s string) *ConnectorUpdate {
cu.mutation.SetType(s)
return cu
func (_u *ConnectorUpdate) SetType(v string) *ConnectorUpdate {
_u.mutation.SetType(v)
return _u
}
// SetNillableType sets the "type" field if the given value is not nil.
func (cu *ConnectorUpdate) SetNillableType(s *string) *ConnectorUpdate {
if s != nil {
cu.SetType(*s)
func (_u *ConnectorUpdate) SetNillableType(v *string) *ConnectorUpdate {
if v != nil {
_u.SetType(*v)
}
return cu
return _u
}
// SetName sets the "name" field.
func (cu *ConnectorUpdate) SetName(s string) *ConnectorUpdate {
cu.mutation.SetName(s)
return cu
func (_u *ConnectorUpdate) SetName(v string) *ConnectorUpdate {
_u.mutation.SetName(v)
return _u
}
// SetNillableName sets the "name" field if the given value is not nil.
func (cu *ConnectorUpdate) SetNillableName(s *string) *ConnectorUpdate {
if s != nil {
cu.SetName(*s)
func (_u *ConnectorUpdate) SetNillableName(v *string) *ConnectorUpdate {
if v != nil {
_u.SetName(*v)
}
return cu
return _u
}
// SetResourceVersion sets the "resource_version" field.
func (cu *ConnectorUpdate) SetResourceVersion(s string) *ConnectorUpdate {
cu.mutation.SetResourceVersion(s)
return cu
func (_u *ConnectorUpdate) SetResourceVersion(v string) *ConnectorUpdate {
_u.mutation.SetResourceVersion(v)
return _u
}
// SetNillableResourceVersion sets the "resource_version" field if the given value is not nil.
func (cu *ConnectorUpdate) SetNillableResourceVersion(s *string) *ConnectorUpdate {
if s != nil {
cu.SetResourceVersion(*s)
func (_u *ConnectorUpdate) SetNillableResourceVersion(v *string) *ConnectorUpdate {
if v != nil {
_u.SetResourceVersion(*v)
}
return cu
return _u
}
// SetConfig sets the "config" field.
func (cu *ConnectorUpdate) SetConfig(b []byte) *ConnectorUpdate {
cu.mutation.SetConfig(b)
return cu
func (_u *ConnectorUpdate) SetConfig(v []byte) *ConnectorUpdate {
_u.mutation.SetConfig(v)
return _u
}
// Mutation returns the ConnectorMutation object of the builder.
func (cu *ConnectorUpdate) Mutation() *ConnectorMutation {
return cu.mutation
func (_u *ConnectorUpdate) Mutation() *ConnectorMutation {
return _u.mutation
}
// Save executes the query and returns the number of nodes affected by the update operation.
func (cu *ConnectorUpdate) Save(ctx context.Context) (int, error) {
return withHooks(ctx, cu.sqlSave, cu.mutation, cu.hooks)
func (_u *ConnectorUpdate) Save(ctx context.Context) (int, error) {
return withHooks(ctx, _u.sqlSave, _u.mutation, _u.hooks)
}
// SaveX is like Save, but panics if an error occurs.
func (cu *ConnectorUpdate) SaveX(ctx context.Context) int {
affected, err := cu.Save(ctx)
func (_u *ConnectorUpdate) SaveX(ctx context.Context) int {
affected, err := _u.Save(ctx)
if err != nil {
panic(err)
}
@@ -95,26 +95,26 @@ func (cu *ConnectorUpdate) SaveX(ctx context.Context) int {
}
// Exec executes the query.
func (cu *ConnectorUpdate) Exec(ctx context.Context) error {
_, err := cu.Save(ctx)
func (_u *ConnectorUpdate) Exec(ctx context.Context) error {
_, err := _u.Save(ctx)
return err
}
// ExecX is like Exec, but panics if an error occurs.
func (cu *ConnectorUpdate) ExecX(ctx context.Context) {
if err := cu.Exec(ctx); err != nil {
func (_u *ConnectorUpdate) ExecX(ctx context.Context) {
if err := _u.Exec(ctx); err != nil {
panic(err)
}
}
// check runs all checks and user-defined validators on the builder.
func (cu *ConnectorUpdate) check() error {
if v, ok := cu.mutation.GetType(); ok {
func (_u *ConnectorUpdate) check() error {
if v, ok := _u.mutation.GetType(); ok {
if err := connector.TypeValidator(v); err != nil {
return &ValidationError{Name: "type", err: fmt.Errorf(`db: validator failed for field "Connector.type": %w`, err)}
}
}
if v, ok := cu.mutation.Name(); ok {
if v, ok := _u.mutation.Name(); ok {
if err := connector.NameValidator(v); err != nil {
return &ValidationError{Name: "name", err: fmt.Errorf(`db: validator failed for field "Connector.name": %w`, err)}
}
@@ -122,31 +122,31 @@ func (cu *ConnectorUpdate) check() error {
return nil
}
func (cu *ConnectorUpdate) sqlSave(ctx context.Context) (n int, err error) {
if err := cu.check(); err != nil {
return n, err
func (_u *ConnectorUpdate) sqlSave(ctx context.Context) (_node int, err error) {
if err := _u.check(); err != nil {
return _node, err
}
_spec := sqlgraph.NewUpdateSpec(connector.Table, connector.Columns, sqlgraph.NewFieldSpec(connector.FieldID, field.TypeString))
if ps := cu.mutation.predicates; len(ps) > 0 {
if ps := _u.mutation.predicates; len(ps) > 0 {
_spec.Predicate = func(selector *sql.Selector) {
for i := range ps {
ps[i](selector)
}
}
}
if value, ok := cu.mutation.GetType(); ok {
if value, ok := _u.mutation.GetType(); ok {
_spec.SetField(connector.FieldType, field.TypeString, value)
}
if value, ok := cu.mutation.Name(); ok {
if value, ok := _u.mutation.Name(); ok {
_spec.SetField(connector.FieldName, field.TypeString, value)
}
if value, ok := cu.mutation.ResourceVersion(); ok {
if value, ok := _u.mutation.ResourceVersion(); ok {
_spec.SetField(connector.FieldResourceVersion, field.TypeString, value)
}
if value, ok := cu.mutation.Config(); ok {
if value, ok := _u.mutation.Config(); ok {
_spec.SetField(connector.FieldConfig, field.TypeBytes, value)
}
if n, err = sqlgraph.UpdateNodes(ctx, cu.driver, _spec); err != nil {
if _node, err = sqlgraph.UpdateNodes(ctx, _u.driver, _spec); err != nil {
if _, ok := err.(*sqlgraph.NotFoundError); ok {
err = &NotFoundError{connector.Label}
} else if sqlgraph.IsConstraintError(err) {
@@ -154,8 +154,8 @@ func (cu *ConnectorUpdate) sqlSave(ctx context.Context) (n int, err error) {
}
return 0, err
}
cu.mutation.done = true
return n, nil
_u.mutation.done = true
return _node, nil
}
// ConnectorUpdateOne is the builder for updating a single Connector entity.
@@ -167,79 +167,79 @@ type ConnectorUpdateOne struct {
}
// SetType sets the "type" field.
func (cuo *ConnectorUpdateOne) SetType(s string) *ConnectorUpdateOne {
cuo.mutation.SetType(s)
return cuo
func (_u *ConnectorUpdateOne) SetType(v string) *ConnectorUpdateOne {
_u.mutation.SetType(v)
return _u
}
// SetNillableType sets the "type" field if the given value is not nil.
func (cuo *ConnectorUpdateOne) SetNillableType(s *string) *ConnectorUpdateOne {
if s != nil {
cuo.SetType(*s)
func (_u *ConnectorUpdateOne) SetNillableType(v *string) *ConnectorUpdateOne {
if v != nil {
_u.SetType(*v)
}
return cuo
return _u
}
// SetName sets the "name" field.
func (cuo *ConnectorUpdateOne) SetName(s string) *ConnectorUpdateOne {
cuo.mutation.SetName(s)
return cuo
func (_u *ConnectorUpdateOne) SetName(v string) *ConnectorUpdateOne {
_u.mutation.SetName(v)
return _u
}
// SetNillableName sets the "name" field if the given value is not nil.
func (cuo *ConnectorUpdateOne) SetNillableName(s *string) *ConnectorUpdateOne {
if s != nil {
cuo.SetName(*s)
func (_u *ConnectorUpdateOne) SetNillableName(v *string) *ConnectorUpdateOne {
if v != nil {
_u.SetName(*v)
}
return cuo
return _u
}
// SetResourceVersion sets the "resource_version" field.
func (cuo *ConnectorUpdateOne) SetResourceVersion(s string) *ConnectorUpdateOne {
cuo.mutation.SetResourceVersion(s)
return cuo
func (_u *ConnectorUpdateOne) SetResourceVersion(v string) *ConnectorUpdateOne {
_u.mutation.SetResourceVersion(v)
return _u
}
// SetNillableResourceVersion sets the "resource_version" field if the given value is not nil.
func (cuo *ConnectorUpdateOne) SetNillableResourceVersion(s *string) *ConnectorUpdateOne {
if s != nil {
cuo.SetResourceVersion(*s)
func (_u *ConnectorUpdateOne) SetNillableResourceVersion(v *string) *ConnectorUpdateOne {
if v != nil {
_u.SetResourceVersion(*v)
}
return cuo
return _u
}
// SetConfig sets the "config" field.
func (cuo *ConnectorUpdateOne) SetConfig(b []byte) *ConnectorUpdateOne {
cuo.mutation.SetConfig(b)
return cuo
func (_u *ConnectorUpdateOne) SetConfig(v []byte) *ConnectorUpdateOne {
_u.mutation.SetConfig(v)
return _u
}
// Mutation returns the ConnectorMutation object of the builder.
func (cuo *ConnectorUpdateOne) Mutation() *ConnectorMutation {
return cuo.mutation
func (_u *ConnectorUpdateOne) Mutation() *ConnectorMutation {
return _u.mutation
}
// Where appends a list predicates to the ConnectorUpdate builder.
func (cuo *ConnectorUpdateOne) Where(ps ...predicate.Connector) *ConnectorUpdateOne {
cuo.mutation.Where(ps...)
return cuo
func (_u *ConnectorUpdateOne) Where(ps ...predicate.Connector) *ConnectorUpdateOne {
_u.mutation.Where(ps...)
return _u
}
// Select allows selecting one or more fields (columns) of the returned entity.
// The default is selecting all fields defined in the entity schema.
func (cuo *ConnectorUpdateOne) Select(field string, fields ...string) *ConnectorUpdateOne {
cuo.fields = append([]string{field}, fields...)
return cuo
func (_u *ConnectorUpdateOne) Select(field string, fields ...string) *ConnectorUpdateOne {
_u.fields = append([]string{field}, fields...)
return _u
}
// Save executes the query and returns the updated Connector entity.
func (cuo *ConnectorUpdateOne) Save(ctx context.Context) (*Connector, error) {
return withHooks(ctx, cuo.sqlSave, cuo.mutation, cuo.hooks)
func (_u *ConnectorUpdateOne) Save(ctx context.Context) (*Connector, error) {
return withHooks(ctx, _u.sqlSave, _u.mutation, _u.hooks)
}
// SaveX is like Save, but panics if an error occurs.
func (cuo *ConnectorUpdateOne) SaveX(ctx context.Context) *Connector {
node, err := cuo.Save(ctx)
func (_u *ConnectorUpdateOne) SaveX(ctx context.Context) *Connector {
node, err := _u.Save(ctx)
if err != nil {
panic(err)
}
@@ -247,26 +247,26 @@ func (cuo *ConnectorUpdateOne) SaveX(ctx context.Context) *Connector {
}
// Exec executes the query on the entity.
func (cuo *ConnectorUpdateOne) Exec(ctx context.Context) error {
_, err := cuo.Save(ctx)
func (_u *ConnectorUpdateOne) Exec(ctx context.Context) error {
_, err := _u.Save(ctx)
return err
}
// ExecX is like Exec, but panics if an error occurs.
func (cuo *ConnectorUpdateOne) ExecX(ctx context.Context) {
if err := cuo.Exec(ctx); err != nil {
func (_u *ConnectorUpdateOne) ExecX(ctx context.Context) {
if err := _u.Exec(ctx); err != nil {
panic(err)
}
}
// check runs all checks and user-defined validators on the builder.
func (cuo *ConnectorUpdateOne) check() error {
if v, ok := cuo.mutation.GetType(); ok {
func (_u *ConnectorUpdateOne) check() error {
if v, ok := _u.mutation.GetType(); ok {
if err := connector.TypeValidator(v); err != nil {
return &ValidationError{Name: "type", err: fmt.Errorf(`db: validator failed for field "Connector.type": %w`, err)}
}
}
if v, ok := cuo.mutation.Name(); ok {
if v, ok := _u.mutation.Name(); ok {
if err := connector.NameValidator(v); err != nil {
return &ValidationError{Name: "name", err: fmt.Errorf(`db: validator failed for field "Connector.name": %w`, err)}
}
@@ -274,17 +274,17 @@ func (cuo *ConnectorUpdateOne) check() error {
return nil
}
func (cuo *ConnectorUpdateOne) sqlSave(ctx context.Context) (_node *Connector, err error) {
if err := cuo.check(); err != nil {
func (_u *ConnectorUpdateOne) sqlSave(ctx context.Context) (_node *Connector, err error) {
if err := _u.check(); err != nil {
return _node, err
}
_spec := sqlgraph.NewUpdateSpec(connector.Table, connector.Columns, sqlgraph.NewFieldSpec(connector.FieldID, field.TypeString))
id, ok := cuo.mutation.ID()
id, ok := _u.mutation.ID()
if !ok {
return nil, &ValidationError{Name: "id", err: errors.New(`db: missing "Connector.id" for update`)}
}
_spec.Node.ID.Value = id
if fields := cuo.fields; len(fields) > 0 {
if fields := _u.fields; len(fields) > 0 {
_spec.Node.Columns = make([]string, 0, len(fields))
_spec.Node.Columns = append(_spec.Node.Columns, connector.FieldID)
for _, f := range fields {
@@ -296,29 +296,29 @@ func (cuo *ConnectorUpdateOne) sqlSave(ctx context.Context) (_node *Connector, e
}
}
}
if ps := cuo.mutation.predicates; len(ps) > 0 {
if ps := _u.mutation.predicates; len(ps) > 0 {
_spec.Predicate = func(selector *sql.Selector) {
for i := range ps {
ps[i](selector)
}
}
}
if value, ok := cuo.mutation.GetType(); ok {
if value, ok := _u.mutation.GetType(); ok {
_spec.SetField(connector.FieldType, field.TypeString, value)
}
if value, ok := cuo.mutation.Name(); ok {
if value, ok := _u.mutation.Name(); ok {
_spec.SetField(connector.FieldName, field.TypeString, value)
}
if value, ok := cuo.mutation.ResourceVersion(); ok {
if value, ok := _u.mutation.ResourceVersion(); ok {
_spec.SetField(connector.FieldResourceVersion, field.TypeString, value)
}
if value, ok := cuo.mutation.Config(); ok {
if value, ok := _u.mutation.Config(); ok {
_spec.SetField(connector.FieldConfig, field.TypeBytes, value)
}
_node = &Connector{config: cuo.config}
_node = &Connector{config: _u.config}
_spec.Assign = _node.assignValues
_spec.ScanValues = _node.scanValues
if err = sqlgraph.UpdateNode(ctx, cuo.driver, _spec); err != nil {
if err = sqlgraph.UpdateNode(ctx, _u.driver, _spec); err != nil {
if _, ok := err.(*sqlgraph.NotFoundError); ok {
err = &NotFoundError{connector.Label}
} else if sqlgraph.IsConstraintError(err) {
@@ -326,6 +326,6 @@ func (cuo *ConnectorUpdateOne) sqlSave(ctx context.Context) (_node *Connector, e
}
return nil, err
}
cuo.mutation.done = true
_u.mutation.done = true
return _node, nil
}
storage/ent/db/devicerequest.go
+25 -25
View File
@@ -55,7 +55,7 @@ func (*DeviceRequest) scanValues(columns []string) ([]any, error) {
// assignValues assigns the values that were returned from sql.Rows (after scanning)
// to the DeviceRequest fields.
func (dr *DeviceRequest) assignValues(columns []string, values []any) error {
func (_m *DeviceRequest) assignValues(columns []string, values []any) error {
if m, n := len(values), len(columns); m < n {
return fmt.Errorf("mismatch number of scan values: %d != %d", m, n)
}
@@ -66,36 +66,36 @@ func (dr *DeviceRequest) assignValues(columns []string, values []any) error {
if !ok {
return fmt.Errorf("unexpected type %T for field id", value)
}
dr.ID = int(value.Int64)
_m.ID = int(value.Int64)
case devicerequest.FieldUserCode:
if value, ok := values[i].(*sql.NullString); !ok {
return fmt.Errorf("unexpected type %T for field user_code", values[i])
} else if value.Valid {
dr.UserCode = value.String
_m.UserCode = value.String
}
case devicerequest.FieldDeviceCode:
if value, ok := values[i].(*sql.NullString); !ok {
return fmt.Errorf("unexpected type %T for field device_code", values[i])
} else if value.Valid {
dr.DeviceCode = value.String
_m.DeviceCode = value.String
}
case devicerequest.FieldClientID:
if value, ok := values[i].(*sql.NullString); !ok {
return fmt.Errorf("unexpected type %T for field client_id", values[i])
} else if value.Valid {
dr.ClientID = value.String
_m.ClientID = value.String
}
case devicerequest.FieldClientSecret:
if value, ok := values[i].(*sql.NullString); !ok {
return fmt.Errorf("unexpected type %T for field client_secret", values[i])
} else if value.Valid {
dr.ClientSecret = value.String
_m.ClientSecret = value.String
}
case devicerequest.FieldScopes:
if value, ok := values[i].(*[]byte); !ok {
return fmt.Errorf("unexpected type %T for field scopes", values[i])
} else if value != nil && len(*value) > 0 {
if err := json.Unmarshal(*value, &dr.Scopes); err != nil {
if err := json.Unmarshal(*value, &_m.Scopes); err != nil {
return fmt.Errorf("unmarshal field scopes: %w", err)
}
}
@@ -103,10 +103,10 @@ func (dr *DeviceRequest) assignValues(columns []string, values []any) error {
if value, ok := values[i].(*sql.NullTime); !ok {
return fmt.Errorf("unexpected type %T for field expiry", values[i])
} else if value.Valid {
dr.Expiry = value.Time
_m.Expiry = value.Time
}
default:
dr.selectValues.Set(columns[i], values[i])
_m.selectValues.Set(columns[i], values[i])
}
}
return nil
@@ -114,50 +114,50 @@ func (dr *DeviceRequest) assignValues(columns []string, values []any) error {
// Value returns the ent.Value that was dynamically selected and assigned to the DeviceRequest.
// This includes values selected through modifiers, order, etc.
func (dr *DeviceRequest) Value(name string) (ent.Value, error) {
return dr.selectValues.Get(name)
func (_m *DeviceRequest) Value(name string) (ent.Value, error) {
return _m.selectValues.Get(name)
}
// Update returns a builder for updating this DeviceRequest.
// Note that you need to call DeviceRequest.Unwrap() before calling this method if this DeviceRequest
// was returned from a transaction, and the transaction was committed or rolled back.
func (dr *DeviceRequest) Update() *DeviceRequestUpdateOne {
return NewDeviceRequestClient(dr.config).UpdateOne(dr)
func (_m *DeviceRequest) Update() *DeviceRequestUpdateOne {
return NewDeviceRequestClient(_m.config).UpdateOne(_m)
}
// Unwrap unwraps the DeviceRequest entity that was returned from a transaction after it was closed,
// so that all future queries will be executed through the driver which created the transaction.
func (dr *DeviceRequest) Unwrap() *DeviceRequest {
_tx, ok := dr.config.driver.(*txDriver)
func (_m *DeviceRequest) Unwrap() *DeviceRequest {
_tx, ok := _m.config.driver.(*txDriver)
if !ok {
panic("db: DeviceRequest is not a transactional entity")
}
dr.config.driver = _tx.drv
return dr
_m.config.driver = _tx.drv
return _m
}
// String implements the fmt.Stringer.
func (dr *DeviceRequest) String() string {
func (_m *DeviceRequest) String() string {
var builder strings.Builder
builder.WriteString("DeviceRequest(")
builder.WriteString(fmt.Sprintf("id=%v, ", dr.ID))
builder.WriteString(fmt.Sprintf("id=%v, ", _m.ID))
builder.WriteString("user_code=")
builder.WriteString(dr.UserCode)
builder.WriteString(_m.UserCode)
builder.WriteString(", ")
builder.WriteString("device_code=")
builder.WriteString(dr.DeviceCode)
builder.WriteString(_m.DeviceCode)
builder.WriteString(", ")
builder.WriteString("client_id=")
builder.WriteString(dr.ClientID)
builder.WriteString(_m.ClientID)
builder.WriteString(", ")
builder.WriteString("client_secret=")
builder.WriteString(dr.ClientSecret)
builder.WriteString(_m.ClientSecret)
builder.WriteString(", ")
builder.WriteString("scopes=")
builder.WriteString(fmt.Sprintf("%v", dr.Scopes))
builder.WriteString(fmt.Sprintf("%v", _m.Scopes))
builder.WriteString(", ")
builder.WriteString("expiry=")
builder.WriteString(dr.Expiry.Format(time.ANSIC))
builder.WriteString(_m.Expiry.Format(time.ANSIC))
builder.WriteByte(')')
return builder.String()
}
storage/ent/db/devicerequest_create.go
+69 -69
View File
@@ -21,54 +21,54 @@ type DeviceRequestCreate struct {
}
// SetUserCode sets the "user_code" field.
func (drc *DeviceRequestCreate) SetUserCode(s string) *DeviceRequestCreate {
drc.mutation.SetUserCode(s)
return drc
func (_c *DeviceRequestCreate) SetUserCode(v string) *DeviceRequestCreate {
_c.mutation.SetUserCode(v)
return _c
}
// SetDeviceCode sets the "device_code" field.
func (drc *DeviceRequestCreate) SetDeviceCode(s string) *DeviceRequestCreate {
drc.mutation.SetDeviceCode(s)
return drc
func (_c *DeviceRequestCreate) SetDeviceCode(v string) *DeviceRequestCreate {
_c.mutation.SetDeviceCode(v)
return _c
}
// SetClientID sets the "client_id" field.
func (drc *DeviceRequestCreate) SetClientID(s string) *DeviceRequestCreate {
drc.mutation.SetClientID(s)
return drc
func (_c *DeviceRequestCreate) SetClientID(v string) *DeviceRequestCreate {
_c.mutation.SetClientID(v)
return _c
}
// SetClientSecret sets the "client_secret" field.
func (drc *DeviceRequestCreate) SetClientSecret(s string) *DeviceRequestCreate {
drc.mutation.SetClientSecret(s)
return drc
func (_c *DeviceRequestCreate) SetClientSecret(v string) *DeviceRequestCreate {
_c.mutation.SetClientSecret(v)
return _c
}
// SetScopes sets the "scopes" field.
func (drc *DeviceRequestCreate) SetScopes(s []string) *DeviceRequestCreate {
drc.mutation.SetScopes(s)
return drc
func (_c *DeviceRequestCreate) SetScopes(v []string) *DeviceRequestCreate {
_c.mutation.SetScopes(v)
return _c
}
// SetExpiry sets the "expiry" field.
func (drc *DeviceRequestCreate) SetExpiry(t time.Time) *DeviceRequestCreate {
drc.mutation.SetExpiry(t)
return drc
func (_c *DeviceRequestCreate) SetExpiry(v time.Time) *DeviceRequestCreate {
_c.mutation.SetExpiry(v)
return _c
}
// Mutation returns the DeviceRequestMutation object of the builder.
func (drc *DeviceRequestCreate) Mutation() *DeviceRequestMutation {
return drc.mutation
func (_c *DeviceRequestCreate) Mutation() *DeviceRequestMutation {
return _c.mutation
}
// Save creates the DeviceRequest in the database.
func (drc *DeviceRequestCreate) Save(ctx context.Context) (*DeviceRequest, error) {
return withHooks(ctx, drc.sqlSave, drc.mutation, drc.hooks)
func (_c *DeviceRequestCreate) Save(ctx context.Context) (*DeviceRequest, error) {
return withHooks(ctx, _c.sqlSave, _c.mutation, _c.hooks)
}
// SaveX calls Save and panics if Save returns an error.
func (drc *DeviceRequestCreate) SaveX(ctx context.Context) *DeviceRequest {
v, err := drc.Save(ctx)
func (_c *DeviceRequestCreate) SaveX(ctx context.Context) *DeviceRequest {
v, err := _c.Save(ctx)
if err != nil {
panic(err)
}
@@ -76,64 +76,64 @@ func (drc *DeviceRequestCreate) SaveX(ctx context.Context) *DeviceRequest {
}
// Exec executes the query.
func (drc *DeviceRequestCreate) Exec(ctx context.Context) error {
_, err := drc.Save(ctx)
func (_c *DeviceRequestCreate) Exec(ctx context.Context) error {
_, err := _c.Save(ctx)
return err
}
// ExecX is like Exec, but panics if an error occurs.
func (drc *DeviceRequestCreate) ExecX(ctx context.Context) {
if err := drc.Exec(ctx); err != nil {
func (_c *DeviceRequestCreate) ExecX(ctx context.Context) {
if err := _c.Exec(ctx); err != nil {
panic(err)
}
}
// check runs all checks and user-defined validators on the builder.
func (drc *DeviceRequestCreate) check() error {
if _, ok := drc.mutation.UserCode(); !ok {
func (_c *DeviceRequestCreate) check() error {
if _, ok := _c.mutation.UserCode(); !ok {
return &ValidationError{Name: "user_code", err: errors.New(`db: missing required field "DeviceRequest.user_code"`)}
}
if v, ok := drc.mutation.UserCode(); ok {
if v, ok := _c.mutation.UserCode(); ok {
if err := devicerequest.UserCodeValidator(v); err != nil {
return &ValidationError{Name: "user_code", err: fmt.Errorf(`db: validator failed for field "DeviceRequest.user_code": %w`, err)}
}
}
if _, ok := drc.mutation.DeviceCode(); !ok {
if _, ok := _c.mutation.DeviceCode(); !ok {
return &ValidationError{Name: "device_code", err: errors.New(`db: missing required field "DeviceRequest.device_code"`)}
}
if v, ok := drc.mutation.DeviceCode(); ok {
if v, ok := _c.mutation.DeviceCode(); ok {
if err := devicerequest.DeviceCodeValidator(v); err != nil {
return &ValidationError{Name: "device_code", err: fmt.Errorf(`db: validator failed for field "DeviceRequest.device_code": %w`, err)}
}
}
if _, ok := drc.mutation.ClientID(); !ok {
if _, ok := _c.mutation.ClientID(); !ok {
return &ValidationError{Name: "client_id", err: errors.New(`db: missing required field "DeviceRequest.client_id"`)}
}
if v, ok := drc.mutation.ClientID(); ok {
if v, ok := _c.mutation.ClientID(); ok {
if err := devicerequest.ClientIDValidator(v); err != nil {
return &ValidationError{Name: "client_id", err: fmt.Errorf(`db: validator failed for field "DeviceRequest.client_id": %w`, err)}
}
}
if _, ok := drc.mutation.ClientSecret(); !ok {
if _, ok := _c.mutation.ClientSecret(); !ok {
return &ValidationError{Name: "client_secret", err: errors.New(`db: missing required field "DeviceRequest.client_secret"`)}
}
if v, ok := drc.mutation.ClientSecret(); ok {
if v, ok := _c.mutation.ClientSecret(); ok {
if err := devicerequest.ClientSecretValidator(v); err != nil {
return &ValidationError{Name: "client_secret", err: fmt.Errorf(`db: validator failed for field "DeviceRequest.client_secret": %w`, err)}
}
}
if _, ok := drc.mutation.Expiry(); !ok {
if _, ok := _c.mutation.Expiry(); !ok {
return &ValidationError{Name: "expiry", err: errors.New(`db: missing required field "DeviceRequest.expiry"`)}
}
return nil
}
func (drc *DeviceRequestCreate) sqlSave(ctx context.Context) (*DeviceRequest, error) {
if err := drc.check(); err != nil {
func (_c *DeviceRequestCreate) sqlSave(ctx context.Context) (*DeviceRequest, error) {
if err := _c.check(); err != nil {
return nil, err
}
_node, _spec := drc.createSpec()
if err := sqlgraph.CreateNode(ctx, drc.driver, _spec); err != nil {
_node, _spec := _c.createSpec()
if err := sqlgraph.CreateNode(ctx, _c.driver, _spec); err != nil {
if sqlgraph.IsConstraintError(err) {
err = &ConstraintError{msg: err.Error(), wrap: err}
}
@@ -141,37 +141,37 @@ func (drc *DeviceRequestCreate) sqlSave(ctx context.Context) (*DeviceRequest, er
}
id := _spec.ID.Value.(int64)
_node.ID = int(id)
drc.mutation.id = &_node.ID
drc.mutation.done = true
_c.mutation.id = &_node.ID
_c.mutation.done = true
return _node, nil
}
func (drc *DeviceRequestCreate) createSpec() (*DeviceRequest, *sqlgraph.CreateSpec) {
func (_c *DeviceRequestCreate) createSpec() (*DeviceRequest, *sqlgraph.CreateSpec) {
var (
_node = &DeviceRequest{config: drc.config}
_node = &DeviceRequest{config: _c.config}
_spec = sqlgraph.NewCreateSpec(devicerequest.Table, sqlgraph.NewFieldSpec(devicerequest.FieldID, field.TypeInt))
)
if value, ok := drc.mutation.UserCode(); ok {
if value, ok := _c.mutation.UserCode(); ok {
_spec.SetField(devicerequest.FieldUserCode, field.TypeString, value)
_node.UserCode = value
}
if value, ok := drc.mutation.DeviceCode(); ok {
if value, ok := _c.mutation.DeviceCode(); ok {
_spec.SetField(devicerequest.FieldDeviceCode, field.TypeString, value)
_node.DeviceCode = value
}
if value, ok := drc.mutation.ClientID(); ok {
if value, ok := _c.mutation.ClientID(); ok {
_spec.SetField(devicerequest.FieldClientID, field.TypeString, value)
_node.ClientID = value
}
if value, ok := drc.mutation.ClientSecret(); ok {
if value, ok := _c.mutation.ClientSecret(); ok {
_spec.SetField(devicerequest.FieldClientSecret, field.TypeString, value)
_node.ClientSecret = value
}
if value, ok := drc.mutation.Scopes(); ok {
if value, ok := _c.mutation.Scopes(); ok {
_spec.SetField(devicerequest.FieldScopes, field.TypeJSON, value)
_node.Scopes = value
}
if value, ok := drc.mutation.Expiry(); ok {
if value, ok := _c.mutation.Expiry(); ok {
_spec.SetField(devicerequest.FieldExpiry, field.TypeTime, value)
_node.Expiry = value
}
@@ -186,16 +186,16 @@ type DeviceRequestCreateBulk struct {
}
// Save creates the DeviceRequest entities in the database.
func (drcb *DeviceRequestCreateBulk) Save(ctx context.Context) ([]*DeviceRequest, error) {
if drcb.err != nil {
return nil, drcb.err
func (_c *DeviceRequestCreateBulk) Save(ctx context.Context) ([]*DeviceRequest, error) {
if _c.err != nil {
return nil, _c.err
}
specs := make([]*sqlgraph.CreateSpec, len(drcb.builders))
nodes := make([]*DeviceRequest, len(drcb.builders))
mutators := make([]Mutator, len(drcb.builders))
for i := range drcb.builders {
specs := make([]*sqlgraph.CreateSpec, len(_c.builders))
nodes := make([]*DeviceRequest, len(_c.builders))
mutators := make([]Mutator, len(_c.builders))
for i := range _c.builders {
func(i int, root context.Context) {
builder := drcb.builders[i]
builder := _c.builders[i]
var mut Mutator = MutateFunc(func(ctx context.Context, m Mutation) (Value, error) {
mutation, ok := m.(*DeviceRequestMutation)
if !ok {
@@ -208,11 +208,11 @@ func (drcb *DeviceRequestCreateBulk) Save(ctx context.Context) ([]*DeviceRequest
var err error
nodes[i], specs[i] = builder.createSpec()
if i < len(mutators)-1 {
_, err = mutators[i+1].Mutate(root, drcb.builders[i+1].mutation)
_, err = mutators[i+1].Mutate(root, _c.builders[i+1].mutation)
} else {
spec := &sqlgraph.BatchCreateSpec{Nodes: specs}
// Invoke the actual operation on the latest mutation in the chain.
if err = sqlgraph.BatchCreate(ctx, drcb.driver, spec); err != nil {
if err = sqlgraph.BatchCreate(ctx, _c.driver, spec); err != nil {
if sqlgraph.IsConstraintError(err) {
err = &ConstraintError{msg: err.Error(), wrap: err}
}
@@ -236,7 +236,7 @@ func (drcb *DeviceRequestCreateBulk) Save(ctx context.Context) ([]*DeviceRequest
}(i, ctx)
}
if len(mutators) > 0 {
if _, err := mutators[0].Mutate(ctx, drcb.builders[0].mutation); err != nil {
if _, err := mutators[0].Mutate(ctx, _c.builders[0].mutation); err != nil {
return nil, err
}
}
@@ -244,8 +244,8 @@ func (drcb *DeviceRequestCreateBulk) Save(ctx context.Context) ([]*DeviceRequest
}
// SaveX is like Save, but panics if an error occurs.
func (drcb *DeviceRequestCreateBulk) SaveX(ctx context.Context) []*DeviceRequest {
v, err := drcb.Save(ctx)
func (_c *DeviceRequestCreateBulk) SaveX(ctx context.Context) []*DeviceRequest {
v, err := _c.Save(ctx)
if err != nil {
panic(err)
}
@@ -253,14 +253,14 @@ func (drcb *DeviceRequestCreateBulk) SaveX(ctx context.Context) []*DeviceRequest
}
// Exec executes the query.
func (drcb *DeviceRequestCreateBulk) Exec(ctx context.Context) error {
_, err := drcb.Save(ctx)
func (_c *DeviceRequestCreateBulk) Exec(ctx context.Context) error {
_, err := _c.Save(ctx)
return err
}
// ExecX is like Exec, but panics if an error occurs.
func (drcb *DeviceRequestCreateBulk) ExecX(ctx context.Context) {
if err := drcb.Exec(ctx); err != nil {
func (_c *DeviceRequestCreateBulk) ExecX(ctx context.Context) {
if err := _c.Exec(ctx); err != nil {
panic(err)
}
}

Some files were not shown because too many files have changed in this diff Show More