-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge branch 'main' into SCRUM-24-bottom-drawer-sheet
- Loading branch information
Showing
40 changed files
with
1,953 additions
and
982 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
|
@@ -2,3 +2,4 @@ | |
/node_modules | ||
*.p12 | ||
*.env | ||
.env* |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
|
@@ -3,6 +3,7 @@ package transactions | |
import ( | ||
"context" | ||
"fmt" | ||
"strings" | ||
"time" | ||
|
||
"backend/internal/models" | ||
|
@@ -27,14 +28,38 @@ func CheckInvestorExists(pool *pgxpool.Pool, investorID string) (bool, error) { | |
} | ||
|
||
func CreateInvestor(pool *pgxpool.Pool, supabaseID string) error { | ||
// Define the INSERT query | ||
query := ` | ||
INSERT INTO investors (supabase_id, first_name, last_name) | ||
VALUES ($1, $2, $3); | ||
INSERT INTO investors ( | ||
supabase_id, | ||
first_name, | ||
last_name, | ||
email, | ||
phone_number, | ||
ssn, | ||
premise, | ||
street, | ||
locality, | ||
state, | ||
zipcode | ||
) | ||
VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11); | ||
` | ||
|
||
// Execute the query, setting first_name and last_name as empty strings | ||
_, err := pool.Exec(context.Background(), query, supabaseID, "", "") | ||
_, err := pool.Exec( | ||
context.Background(), | ||
query, | ||
supabaseID, | ||
"John", | ||
"Doe", | ||
"[email protected]", | ||
"000-000-0000", | ||
"000-00-0000", | ||
"123", | ||
"Main St", | ||
"Anytown", | ||
"MA", | ||
"12345", | ||
) | ||
if err != nil { | ||
return fmt.Errorf("failed to insert investor: %w", err) | ||
} | ||
|
@@ -43,17 +68,125 @@ func CreateInvestor(pool *pgxpool.Pool, supabaseID string) error { | |
} | ||
|
||
func GetProfile(db *pgxpool.Pool, investorId uuid.UUID) (models.InvestorProfile, error) { | ||
query := "SELECT first_name, last_name FROM investors WHERE supabase_id = $1" | ||
query := "SELECT first_name, last_name, email, phone_number, ssn, premise, COALESCE(subpremise, '') as subpremise, street, locality, state, zipcode, COALESCE(profile_picture_url, '') as profile_picture_url FROM investors WHERE supabase_id = $1" | ||
|
||
var investorProfile models.InvestorProfile | ||
err := db.QueryRow(context.Background(), query, investorId).Scan(&investorProfile.FirstName, &investorProfile.LastName) | ||
err := db.QueryRow(context.Background(), query, investorId).Scan( | ||
&investorProfile.FirstName, | ||
&investorProfile.LastName, | ||
&investorProfile.Email, | ||
&investorProfile.PhoneNumber, | ||
&investorProfile.SSN, | ||
&investorProfile.Premise, | ||
&investorProfile.Subpremise, | ||
&investorProfile.Street, | ||
&investorProfile.Locality, | ||
&investorProfile.State, | ||
&investorProfile.Zipcode, | ||
&investorProfile.ProfilePictureUrl, | ||
) | ||
|
||
if err != nil { | ||
return models.InvestorProfile{}, err | ||
} | ||
|
||
return investorProfile, nil | ||
} | ||
|
||
func UpdateProfile(db *pgxpool.Pool, investorID uuid.UUID, investorProfile models.InvestorProfile) (models.InvestorProfile, error) { | ||
var setFields []string | ||
var args []interface{} | ||
argPosition := 1 | ||
|
||
args = append(args, investorID) | ||
|
||
// TODO: validation is probably important | ||
if investorProfile.FirstName != "" { | ||
argPosition++ | ||
setFields = append(setFields, fmt.Sprintf("first_name = $%d", argPosition)) | ||
args = append(args, investorProfile.FirstName) | ||
} | ||
|
||
if investorProfile.LastName != "" { | ||
argPosition++ | ||
setFields = append(setFields, fmt.Sprintf("last_name = $%d", argPosition)) | ||
args = append(args, investorProfile.LastName) | ||
} | ||
|
||
if investorProfile.Email != "" { | ||
argPosition++ | ||
setFields = append(setFields, fmt.Sprintf("email = $%d", argPosition)) | ||
args = append(args, investorProfile.Email) | ||
} | ||
|
||
if investorProfile.PhoneNumber != "" { | ||
argPosition++ | ||
setFields = append(setFields, fmt.Sprintf("phone_number = $%d", argPosition)) | ||
args = append(args, investorProfile.PhoneNumber) | ||
} | ||
|
||
if investorProfile.SSN != "" { | ||
argPosition++ | ||
setFields = append(setFields, fmt.Sprintf("ssn = $%d", argPosition)) | ||
args = append(args, investorProfile.SSN) | ||
} | ||
|
||
if investorProfile.Premise != "" { | ||
argPosition++ | ||
setFields = append(setFields, fmt.Sprintf("premise = $%d", argPosition)) | ||
args = append(args, investorProfile.Premise) | ||
} | ||
|
||
if investorProfile.Subpremise != "" { | ||
argPosition++ | ||
setFields = append(setFields, fmt.Sprintf("subpremise = $%d", argPosition)) | ||
args = append(args, investorProfile.Subpremise) | ||
} | ||
|
||
if investorProfile.Street != "" { | ||
argPosition++ | ||
setFields = append(setFields, fmt.Sprintf("street = $%d", argPosition)) | ||
args = append(args, investorProfile.Street) | ||
} | ||
|
||
if investorProfile.Locality != "" { | ||
argPosition++ | ||
setFields = append(setFields, fmt.Sprintf("locality = $%d", argPosition)) | ||
args = append(args, investorProfile.Locality) | ||
} | ||
|
||
if investorProfile.State != "" { | ||
argPosition++ | ||
setFields = append(setFields, fmt.Sprintf("state = $%d", argPosition)) | ||
args = append(args, investorProfile.State) | ||
} | ||
|
||
if investorProfile.Zipcode != "" { | ||
argPosition++ | ||
setFields = append(setFields, fmt.Sprintf("zipcode = $%d", argPosition)) | ||
args = append(args, investorProfile.Zipcode) | ||
} | ||
|
||
if investorProfile.ProfilePictureUrl != "" { | ||
argPosition++ | ||
setFields = append(setFields, fmt.Sprintf("profile_picture_url = $%d", argPosition)) | ||
args = append(args, investorProfile.ProfilePictureUrl) | ||
} | ||
|
||
// If no fields to update, return early | ||
if len(setFields) == 0 { | ||
return GetProfile(db, investorID) | ||
} | ||
|
||
query := fmt.Sprintf("UPDATE investors SET %s WHERE supabase_id = $1", strings.Join(setFields, ", ")) | ||
_, err := db.Exec(context.Background(), query, args...) | ||
if err != nil { | ||
return models.InvestorProfile{}, err | ||
} | ||
|
||
return GetProfile(db, investorID) | ||
} | ||
|
||
func GetHistory(db *pgxpool.Pool, investorID uuid.UUID, limit int, offset int) ([]models.HistoryEntry, error) { | ||
query := "SELECT created_at, project_id, funded_cents FROM investor_investments WHERE investor_id = $1 ORDER BY created_at LIMIT $2 OFFSET $3" | ||
rows, err := db.Query(context.Background(), query, investorID, limit, offset) | ||
|
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
|
@@ -65,6 +65,41 @@ INSERT INTO | |
auth.users | ||
); | ||
|
||
-- test investor data matching auth users | ||
INSERT INTO | ||
investors ( | ||
supabase_id, | ||
first_name, | ||
last_name, | ||
email, | ||
phone_number, | ||
ssn, | ||
premise, | ||
subpremise, | ||
street, | ||
locality, | ||
state, | ||
zipcode, | ||
profile_picture_url | ||
) ( | ||
select | ||
id, | ||
'Test', | ||
'User' || (ROW_NUMBER() OVER ()), | ||
email, | ||
'555-555-5555', | ||
'123-45-6789', | ||
'123', | ||
null, | ||
'Main St', | ||
'Boston', | ||
'MA', | ||
'02115', | ||
'https://api.dicebear.com/7.x/avataaars/svg?seed=' || (ROW_NUMBER() OVER ()) | ||
from | ||
auth.users | ||
); | ||
|
||
-- SQLBook: Code | ||
INSERT INTO contributors (first_name, last_name, email) VALUES ('Michael', 'Brennan', '[email protected]'); | ||
INSERT INTO contributors (first_name, last_name, email) VALUES ('Ryan', 'Saperstein', '[email protected]'); | ||
|
@@ -84,9 +119,6 @@ INSERT INTO project_images (project_id, image_url) VALUES ('d09c8f0f-13d3-4336-9 | |
INSERT INTO project_images (project_id, image_url) VALUES ('d09c8f0f-13d3-4336-92e9-b0b2c8bce570', 'https://cdn2.thecatapi.com/images/MjA1MTYzNg.jpg'); | ||
INSERT INTO project_images (project_id, image_url) VALUES ('d09c8f0f-13d3-4336-92e9-b0b2c8bce570', 'https://cdn2.thecatapi.com/images/MuEGe1-Sz.jpg'); | ||
|
||
INSERT INTO investors (supabase_id, first_name, last_name) VALUES ((SELECT id from auth.users where email='[email protected]'), 'Dwight', 'Howard'); | ||
INSERT INTO investors (supabase_id, first_name, last_name) VALUES ((SELECT id from auth.users where email='[email protected]'), 'Taj', 'Gibson'); | ||
|
||
INSERT INTO investor_investments (id, project_id, investor_id, funded_cents) VALUES ('bdd66406-64bd-41a5-b797-a486751ea429', 'c3733692-5a86-441f-8ad0-9c32c648bb72', (SELECT id FROM auth.users WHERE email='[email protected]'), '1200'); | ||
INSERT INTO investor_investments (id, project_id, investor_id, funded_cents) VALUES ('ba995313-1b8a-4b4e-ad02-0b72efd22309', 'c3733692-5a86-441f-8ad0-9c32c648bb72', (SELECT id FROM auth.users WHERE email='[email protected]'), '400'); | ||
INSERT INTO investor_investments (id, project_id, investor_id, funded_cents) VALUES ('de194a16-c0be-4519-bf6a-9a3bceea1b42', 'c3733692-5a86-441f-8ad0-9c32c648bb72', (SELECT id FROM auth.users WHERE email='[email protected]'), '800'); | ||
|
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Loading
Sorry, something went wrong. Reload?
Sorry, we cannot display this file.
Sorry, this file is invalid so it cannot be displayed.
Loading
Sorry, something went wrong. Reload?
Sorry, we cannot display this file.
Sorry, this file is invalid so it cannot be displayed.
Oops, something went wrong.