otter-space-sdk/pkg/impl.go

package pkg

import (
	"context"

	"git.dragse.it/anthrove/anthrove-graph-sdk.git/internal"
	"git.dragse.it/anthrove/anthrove-graph-sdk.git/pkg/models"
	"github.com/neo4j/neo4j-go-driver/v5/neo4j"
	"github.com/neo4j/neo4j-go-driver/v5/neo4j/config"
)

type graphConnection struct {
	driver     neo4j.DriverWithContext
	graphDebug bool
}

func NewGraphConnection(graphDebug bool) Graph {
	return &graphConnection{
		driver:     nil,
		graphDebug: graphDebug,
	}
}

func (g *graphConnection) Connect(ctx context.Context, endpoint string, username string, password string) error {
	driver, err := neo4j.NewDriverWithContext(endpoint, neo4j.BasicAuth(username, password, ""),
		logger(g.graphDebug))

	if err != nil {
		return err
	}
	err = driver.VerifyAuthentication(ctx, nil)
	if err != nil {
		return err
	}
	g.driver = driver
	return nil
}

func (g *graphConnection) AddUserWithRelationToSource(ctx context.Context, anthroveUserID models.AnthroveUserID, sourceDomain string, userID string, username string) (*models.AnthroveUser, error) {
	return internal.CreateUserNodeWithSourceRelation(ctx, g.driver, anthroveUserID, sourceDomain, userID, username)
}

func (g *graphConnection) AddSource(ctx context.Context, anthroveSource *models.AnthroveSource) error {
	return internal.CreateSourceNode(ctx, g.driver, anthroveSource)
}

func (g *graphConnection) AddPost(ctx context.Context, anthrovePost *models.AnthrovePost) error {
	return internal.CreateAnthrovePostNode(ctx, g.driver, anthrovePost)
}

func (g *graphConnection) AddTagWithRelationToPost(ctx context.Context, anthrovePostID *models.AnthrovePostID, anthroveTag *models.AnthroveTag) error {
	return internal.CreateTagNodeWitRelation(ctx, g.driver, anthrovePostID, anthroveTag)
}

func (g *graphConnection) LinkPostWithSource(ctx context.Context, anthrovePostID models.AnthrovePostID, anthroveSourceDomain string, anthrovePostRelationship *models.AnthrovePostRelationship) error {
	return internal.EstablishAnthrovePostToSourceLink(ctx, g.driver, anthrovePostID, anthroveSourceDomain, anthrovePostRelationship)
}

func (g *graphConnection) LinkUserWithPost(ctx context.Context, anthroveUser *models.AnthroveUser, anthrovePost *models.AnthrovePost) error {
	return internal.EstablishUserToPostLink(ctx, g.driver, anthroveUser, anthrovePost)
}

func (g *graphConnection) VerifyUserPostLink(ctx context.Context, anthrovePost *models.AnthrovePost, anthroveUser *models.AnthroveUser) (bool, error) {
	//TODO implement me
	panic("implement me")
}

func (g *graphConnection) CheckPostNodeExistsByAnthroveID(ctx context.Context, anthrovePost *models.AnthrovePost) (bool, error) {
	//TODO implement me
	panic("implement me")
}

func (g *graphConnection) CheckPostNodeExistsBySourceURL(ctx context.Context, anthroveSource *models.AnthroveSource) (bool, error) {
	//TODO implement me
	panic("implement me")
}

func (g *graphConnection) CheckPostNodeExistsBySourceID(ctx context.Context, anthroveSource *models.AnthroveSource) (bool, error) {
	//TODO implement me
	panic("implement me")
}

func (g *graphConnection) GetUserFavoriteCount(ctx context.Context, anthroveUser *models.AnthroveUser) (int64, error) {
	//TODO implement me
	panic("implement me")
}

func (g *graphConnection) GetUserSourceLinks(ctx context.Context, anthroveUser *models.AnthroveUser) (map[string]models.AnthroveUserRelationship, error) {
	//TODO implement me
	panic("implement me")
}

func (g *graphConnection) GetAnthroveUser(ctx context.Context, anthroveUser *models.AnthroveUser) (*models.AnthroveUser, error) {
	//TODO implement me
	panic("implement me")
}

func (g *graphConnection) GetAllAnthroveUserIDs(ctx context.Context) ([]models.AnthroveUserID, error) {
	//TODO implement me
	panic("implement me")
}

func logger(graphDebug bool) func(config *config.Config) {
	return func(config *config.Config) {
		config.Log = internal.NewGraphLogger(graphDebug)
	}
}