Merge branch 'master' into gRPC-endpoints

bff/db/mock/store.go

@@ -54,6 +54,20 @@ func (mr *MockStoreMockRecorder) BlockSession(arg0, arg1 any) *gomock.Call {
 	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "BlockSession", reflect.TypeOf((*MockStore)(nil).BlockSession), arg0, arg1)
 }
 
+// CloneProviders mocks base method.
+func (m *MockStore) CloneProviders(arg0 context.Context, arg1 db.CloneProvidersParams) error {
+	m.ctrl.T.Helper()
+	ret := m.ctrl.Call(m, "CloneProviders", arg0, arg1)
+	ret0, _ := ret[0].(error)
+	return ret0
+}
+
+// CloneProviders indicates an expected call of CloneProviders.
+func (mr *MockStoreMockRecorder) CloneProviders(arg0, arg1 any) *gomock.Call {
+	mr.mock.ctrl.T.Helper()
+	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "CloneProviders", reflect.TypeOf((*MockStore)(nil).CloneProviders), arg0, arg1)
+}
+
 // CreateAccount mocks base method.
 func (m *MockStore) CreateAccount(arg0 context.Context, arg1 db.CreateAccountParams) (db.Account, error) {
 	m.ctrl.T.Helper()
@@ -481,6 +495,21 @@ func (mr *MockStoreMockRecorder) GetReturn(arg0, arg1 any) *gomock.Call {
 	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetReturn", reflect.TypeOf((*MockStore)(nil).GetReturn), arg0, arg1)
 }
 
+// GetReturns mocks base method.
+func (m *MockStore) GetReturns(arg0 context.Context, arg1 int64) ([]db.Return, error) {
+	m.ctrl.T.Helper()
+	ret := m.ctrl.Call(m, "GetReturns", arg0, arg1)
+	ret0, _ := ret[0].([]db.Return)
+	ret1, _ := ret[1].(error)
+	return ret0, ret1
+}
+
+// GetReturns indicates an expected call of GetReturns.
+func (mr *MockStoreMockRecorder) GetReturns(arg0, arg1 any) *gomock.Call {
+	mr.mock.ctrl.T.Helper()
+	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetReturns", reflect.TypeOf((*MockStore)(nil).GetReturns), arg0, arg1)
+}
+
 // GetReturnsLog mocks base method.
 func (m *MockStore) GetReturnsLog(arg0 context.Context, arg1 int64) (db.ReturnsLog, error) {
 	m.ctrl.T.Helper()

bff/db/query/person.sql

@@ -43,3 +43,7 @@ RETURNING *;
 -- name: DeletePerson :exec
 DELETE FROM persons
 WHERE "id" = $1;
+
+-- name: GetReturns :many
+SELECT * FROM returns
+WHERE "person_id" = sqlc.arg(id);

bff/db/query/return.sql

@@ -49,3 +49,27 @@ RETURNING *;
 -- name: DeleteReturn :exec
 DELETE FROM returns
 WHERE "id" = sqlc.arg(id);
+
+-- name: CloneProviders :exec
+INSERT INTO returns (
+    "provider_id",
+    "name",
+    "description",
+    "category",
+    "email",
+    "status",
+    "creator",
+    "changer",
+    "person_id"
+)
+SELECT 
+    "id",
+    "name",
+    "description",
+    "category",
+    "email",
+    'new',
+    sqlc.arg(creator),
+    sqlc.arg(creator),
+    sqlc.arg(person_id)
+FROM providers;

bff/db/sqlc/person.sql.go

@@ -109,6 +109,47 @@ func (q *Queries) GetPerson(ctx context.Context, id int64) (Person, error) {
 	return i, err
 }
 
+const getReturns = `-- name: GetReturns :many
+SELECT id, person_id, provider_id, name, description, category, email, status, creator, created, changer, changed FROM returns
+WHERE "person_id" = $1
+`
+
+func (q *Queries) GetReturns(ctx context.Context, id int64) ([]Return, error) {
+	rows, err := q.db.QueryContext(ctx, getReturns, id)
+	if err != nil {
+		return nil, err
+	}
+	defer rows.Close()
+	items := []Return{}
+	for rows.Next() {
+		var i Return
+		if err := rows.Scan(
+			&i.ID,
+			&i.PersonID,
+			&i.ProviderID,
+			&i.Name,
+			&i.Description,
+			&i.Category,
+			&i.Email,
+			&i.Status,
+			&i.Creator,
+			&i.Created,
+			&i.Changer,
+			&i.Changed,
+		); err != nil {
+			return nil, err
+		}
+		items = append(items, i)
+	}
+	if err := rows.Close(); err != nil {
+		return nil, err
+	}
+	if err := rows.Err(); err != nil {
+		return nil, err
+	}
+	return items, nil
+}
+
 const listPersons = `-- name: ListPersons :many
 SELECT id, account_id, firstname, lastname, birthday, city, zip, street, country, creator, created, changer, changed FROM persons
 ORDER BY "lastname", "firstname"

bff/db/sqlc/querier.go

@@ -12,6 +12,7 @@ import (
 
 type Querier interface {
 	BlockSession(ctx context.Context, id uuid.UUID) error
+	CloneProviders(ctx context.Context, arg CloneProvidersParams) error
 	CreateAccount(ctx context.Context, arg CreateAccountParams) (Account, error)
 	CreateDocumentMail(ctx context.Context, arg CreateDocumentMailParams) (Document, error)
 	CreateDocumentUpload(ctx context.Context, arg CreateDocumentUploadParams) (Document, error)
@@ -52,6 +53,7 @@ type Querier interface {
 	GetPerson(ctx context.Context, id int64) (Person, error)
 	GetProvider(ctx context.Context, id int64) (Provider, error)
 	GetReturn(ctx context.Context, id int64) (Return, error)
+	GetReturns(ctx context.Context, id int64) ([]Return, error)
 	GetReturnsLog(ctx context.Context, id int64) (ReturnsLog, error)
 	GetSession(ctx context.Context, id uuid.UUID) (Session, error)
 	InvalidateDocument(ctx context.Context, arg InvalidateDocumentParams) (Document, error)

bff/db/sqlc/return.sql.go

@@ -10,6 +10,41 @@ import (
 	"database/sql"
 )
 
+const cloneProviders = `-- name: CloneProviders :exec
+INSERT INTO returns (
+    "provider_id",
+    "name",
+    "description",
+    "category",
+    "email",
+    "status",
+    "creator",
+    "changer",
+    "person_id"
+)
+SELECT 
+    "id",
+    "name",
+    "description",
+    "category",
+    "email",
+    'new',
+    $1,
+    $1,
+    $2
+FROM providers
+`
+
+type CloneProvidersParams struct {
+	Creator  string `json:"creator"`
+	PersonID int64  `json:"person_id"`
+}
+
+func (q *Queries) CloneProviders(ctx context.Context, arg CloneProvidersParams) error {
+	_, err := q.db.ExecContext(ctx, cloneProviders, arg.Creator, arg.PersonID)
+	return err
+}
+
 const createReturn = `-- name: CreateReturn :one
 INSERT INTO returns (
     "person_id",

bff/db/sqlc/tx_create_person.go

@@ -29,7 +29,14 @@ func (store *SQLStore) CreatePersonTx(ctx context.Context, arg CreatePersonTxPar
 		var err error
 
 		result.Person, err = q.CreatePerson(ctx, CreatePersonParams(arg))
+		if err != nil {
+			return err
+		}
 
+		err = q.CloneProviders(ctx, CloneProvidersParams{
+			Creator:  arg.Creator,
+			PersonID: result.Person.ID,
+		})
 		return err
 	})