Skip to content

User relationships #67

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
dviator wants to merge 3 commits into
base: master
Choose a base branch
from
Open

User relationships #67

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
13ed346
graphql side of adding userRelationships entity
dviator Dec 5, 2020
d20763e
merged ratings fix from master
dviator Dec 12, 2020
a1fe6dd
added userRelationships entity to record follower/followee status amo…
dviator Jan 19, 2021
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions database/migrations/000007_create_user_relationships.down.sql
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
DROP TABLE user_relationships;
9 changes: 9 additions & 0 deletions database/migrations/000007_create_user_relationships.up.sql
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,9 @@
CREATE TABLE IF NOT EXISTS user_relationships
(
id BIGSERIAL PRIMARY KEY,
follower_id int REFERENCES users(id),
followee_id int REFERENCES users(id),
created_at timestamp with time zone NOT NULL,
updated_at timestamp with time zone NOT NULL,
UNIQUE(follower_id, followee_id)
);
80 changes: 80 additions & 0 deletions database/userRelationship.go
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,80 @@
package database

import (
"time"

log "github.com/sirupsen/logrus"
"github.com/well-informed/wellinformed/graph/model"
)

func (db DB) SaveUserRelationship(followerID int64, followeeID int64) (*model.UserRelationship, error) {
stmt := `INSERT INTO user_relationships
(
follower_id,
followee_id,
created_at,
updated_at
)
VALUES($1, $2, $3, $4)
ON CONFLICT (follower_id, followee_id)
DO UPDATE SET
follower_id = $1,
followee_id = $2,
updated_at = $3
RETURNING id, created_at, updated_at`
var ID int64
var CreatedAt time.Time
var UpdatedAt time.Time
err := db.QueryRowx(stmt,
followerID,
followeeID,
time.Now(),
time.Now(),
).Scan(&ID, &CreatedAt, &UpdatedAt)
if err != nil {
log.Error("failed to save interactions entry: err: ", err)
return nil, err
}
userRelationship := &model.UserRelationship{
ID: ID,
Follower: followerID,
Followee: followeeID,
CreatedAt: CreatedAt,
UpdatedAt: UpdatedAt,
}
return userRelationship, nil
}

func (db DB) DeleteUserRelationship(followerID int64, followeeID int64) error {
stmt := `DELETE FROM user_relationships WHERE follower_id = $1 AND followee_id = $2`
_, err := db.Exec(stmt, followerID, followeeID)
if err != nil {
log.Error("unable to delete user relationship", err)
return err
}
return nil
}

func (db DB) ListUserRelationshipsByFollowerID(followerID int64) ([]*model.UserRelationship, error) {
stmt := `SELECT * FROM user_relationships WHERE follower_id = $1`

userRelationships := make([]*model.UserRelationship, 0)
err := db.Select(&userRelationships, stmt, followerID)
if err != nil {
log.Error("error listing relationships by follower ID", err)
return nil, err
}
return userRelationships, nil
}

func (db DB) ListUserRelationshipsByFolloweeID(followeeID int64) ([]*model.UserRelationship, error) {
stmt := `SELECT * FROM user_relationships WHERE followee_id = $1`

userRelationships := make([]*model.UserRelationship, 0)
err := db.Select(&userRelationships, stmt, followeeID)
if err != nil {
log.Error("error listing relationships by followee ID", err)
return nil, err
}
return userRelationships, nil
}
28 changes: 28 additions & 0 deletions graph/Follow.go
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,28 @@
package graph

import (
"context"
"errors"

log "github.com/sirupsen/logrus"
"github.com/well-informed/wellinformed/graph/model"
)

func (r *mutationResolver) followUser(ctx context.Context, user *model.User, input model.UserRelationshipInput) (*model.UserRelationship, error) {
if user.ID != input.FollowerID {
return nil, errors.New("follower must be signed in user")
}
return r.DB.SaveUserRelationship(input.FollowerID, input.FolloweeID)
}

func (r *mutationResolver) unfollowUser(ctx context.Context, user *model.User, input model.UserRelationshipInput) (*model.DeleteResponse, error) {
if user.ID != input.FollowerID {
return &model.DeleteResponse{Ok: false}, errors.New("follower must be signed in user")
}
err := r.DB.DeleteUserRelationship(input.FollowerID, input.FolloweeID)
if err != nil {
log.Error("unable to delete user relationship")
return &model.DeleteResponse{Ok: false}, err
}
return &model.DeleteResponse{Ok: true}, nil
}
Loading