Skip to content

Commit

Permalink
fixed merge api changes
Browse files Browse the repository at this point in the history
  • Loading branch information
@vsumit89
vsumit89 committed Sep 4, 2022
1 parent d0c9e43 commit dffb1e6
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 231 deletions.
235 changes: 5 additions & 230 deletions api/graph/resolvers/sitemap.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -2,241 +2,16 @@ package resolvers

import (
"context"
"encoding/json"
"fmt"
"net/http"
"time"

"github.com/factly/dega-api/config"
"github.com/factly/dega-api/graph/generated"
"github.com/factly/dega-api/graph/models"
"github.com/factly/dega-api/graph/validator"
httpx "github.com/factly/dega-api/util/httpx"
"github.com/spf13/viper"
)

func (r *queryResolver) Sitemap(ctx context.Context) (*models.Sitemaps, error) {
var ok models.Sitemaps = "OKAY"
return &ok, nil
func (r *sitemapResolver) PublishedDate(ctx context.Context, obj *models.Sitemap) (*time.Time, error) {
return &obj.PublishedAt, nil
}

func (r *sitemapsResolver) Categories(ctx context.Context, obj *models.Sitemaps) ([]*models.Sitemap, error) {
sID, err := validator.GetSpace(ctx)
if err != nil {
return nil, err
}
func (r *Resolver) Sitemap() generated.SitemapResolver { return &sitemapResolver{r} }

categories := []models.Category{}

config.DB.Model(&models.Category{}).Where("space_id in (?)", sID).Find(&categories)
nodes := []*models.Sitemap{}

for _, category := range categories {
sitemap := &models.Sitemap{
ID: fmt.Sprint(category.ID),
Slug: category.Slug,
CreatedAt: category.CreatedAt,
}
nodes = append(nodes, sitemap)
}
return nodes, nil
}

func (r *sitemapsResolver) Tags(ctx context.Context, obj *models.Sitemaps) ([]*models.Sitemap, error) {
sID, err := validator.GetSpace(ctx)
if err != nil {
return nil, err
}
tags := []models.Tag{}

config.DB.Model(&models.Tag{}).Where("space_id in (?)", sID).Find(&tags)
nodes := []*models.Sitemap{}

for _, tag := range tags {
sitemap := &models.Sitemap{
ID: fmt.Sprint(tag.ID),
Slug: tag.Slug,
CreatedAt: tag.CreatedAt,
}
nodes = append(nodes, sitemap)
}
return nodes, nil
}

func (r *sitemapsResolver) Users(ctx context.Context, obj *models.Sitemaps) ([]*models.Sitemap, error) {

sID, err := validator.GetSpace(ctx)
if err != nil {
return nil, nil
}

post := &models.Post{}
post.SpaceID = sID

err = config.DB.First(post).Error
if err != nil {
return nil, nil
}

postAuthor := &models.PostAuthor{}
postAuthor.PostID = post.ID

err = config.DB.First(postAuthor).Error
if err != nil {
return nil, nil
}

space := &models.Space{}
space.ID = sID

err = config.DB.First(space).Error
if err != nil {
return nil, nil
}

url := fmt.Sprint(viper.GetString("kavach_url"), "/organisations/", space.OrganisationID, "/users")

req, err := http.NewRequest("GET", url, nil)
if err != nil {
return nil, nil
}

req.Header.Set("Content-Type", "application/json")
req.Header.Set("X-User", fmt.Sprint(postAuthor.AuthorID))
client := httpx.CustomHttpClient()
resp, err := client.Do(req)

if err != nil {
return nil, nil
}

defer resp.Body.Close()

users := []*models.User{}
err = json.NewDecoder(resp.Body).Decode(&users)

if err != nil {
return nil, nil
}

nodes := []*models.Sitemap{}

for _, user := range users {
sitemap := &models.Sitemap{
ID: fmt.Sprint(user.ID),
Slug: fmt.Sprint(user.ID),
CreatedAt: user.CreatedAt,
}
nodes = append(nodes, sitemap)
}
return nodes, nil
}

func (r *sitemapsResolver) Formats(ctx context.Context, obj *models.Sitemaps) ([]*models.Sitemap, error) {
sID, err := validator.GetSpace(ctx)
if err != nil {
return nil, err
}
formats := []models.Format{}

config.DB.Model(&models.Format{}).Where("space_id in (?)", sID).Find(&formats)
nodes := []*models.Sitemap{}

for _, format := range formats {
sitemap := &models.Sitemap{
ID: fmt.Sprint(format.ID),
Slug: format.Slug,
CreatedAt: format.CreatedAt,
}
nodes = append(nodes, sitemap)
}
return nodes, nil
}

func (r *sitemapsResolver) Posts(ctx context.Context, obj *models.Sitemaps) ([]*models.Sitemap, error) {
sID, err := validator.GetSpace(ctx)
if err != nil {
return nil, err
}
posts := []models.Post{}

config.DB.Model(&models.Post{}).Where("space_id in (?)", sID).Find(&posts)
nodes := []*models.Sitemap{}

for _, post := range posts {
sitemap := &models.Sitemap{
ID: fmt.Sprint(post.ID),
Slug: post.Slug,
CreatedAt: post.CreatedAt,
}
nodes = append(nodes, sitemap)
}
return nodes, nil
}

func (r *sitemapsResolver) Claims(ctx context.Context, obj *models.Sitemaps) ([]*models.Sitemap, error) {
sID, err := validator.GetSpace(ctx)
if err != nil {
return nil, err
}
claims := []models.Claim{}

config.DB.Model(&models.Claim{}).Where("space_id in (?)", sID).Find(&claims)
nodes := []*models.Sitemap{}

for _, claim := range claims {
sitemap := &models.Sitemap{
ID: fmt.Sprint(claim.ID),
Slug: claim.Slug,
CreatedAt: claim.CreatedAt,
}
nodes = append(nodes, sitemap)
}
return nodes, nil
}

func (r *sitemapsResolver) Claimants(ctx context.Context, obj *models.Sitemaps) ([]*models.Sitemap, error) {
sID, err := validator.GetSpace(ctx)
if err != nil {
return nil, err
}
claimants := []models.Claimant{}

config.DB.Model(&models.Claimant{}).Where("space_id in (?)", sID).Find(&claimants)
nodes := []*models.Sitemap{}

for _, claimant := range claimants {
sitemap := &models.Sitemap{
ID: fmt.Sprint(claimant.ID),
Slug: claimant.Slug,
CreatedAt: claimant.CreatedAt,
}
nodes = append(nodes, sitemap)
}
return nodes, nil
}

func (r *sitemapsResolver) Ratings(ctx context.Context, obj *models.Sitemaps) ([]*models.Sitemap, error) {
sID, err := validator.GetSpace(ctx)
if err != nil {
return nil, err
}
ratings := []models.Rating{}

config.DB.Model(&models.Rating{}).Where("space_id in (?)", sID).Find(&ratings)
nodes := []*models.Sitemap{}

for _, rating := range ratings {
sitemap := &models.Sitemap{
ID: fmt.Sprint(rating.ID),
Slug: rating.Slug,
CreatedAt: rating.CreatedAt,
}
nodes = append(nodes, sitemap)
}
return nodes, nil
}

// Sitemaps model resolver
func (r *Resolver) Sitemaps() generated.SitemapsResolver { return &sitemapsResolver{r} }

type sitemapsResolver struct{ *Resolver }
type sitemapResolver struct{ *Resolver }
3 changes: 2 additions & 1 deletion api/graph/resolvers/sitemaps.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -11,6 +11,7 @@ import (
"github.com/factly/dega-api/graph/generated"
"github.com/factly/dega-api/graph/models"
"github.com/factly/dega-api/graph/validator"
"github.com/factly/dega-api/util/httpx"
"github.com/spf13/viper"
)

Expand Down Expand Up @@ -104,7 +105,7 @@ func (r *sitemapsResolver) Users(ctx context.Context, obj *models.Sitemaps) ([]*

req.Header.Set("Content-Type", "application/json")
req.Header.Set("X-User", fmt.Sprint(postAuthor.AuthorID))
client := &http.Client{}
client := httpx.CustomHttpClient()
resp, err := client.Do(req)

if err != nil {
Expand Down

0 comments on commit dffb1e6

Please sign in to comment.