jobseekerapi.go

package main

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

	"go.mongodb.org/mongo-driver/bson"

	"github.com/gorilla/mux"

	"go.mongodb.org/mongo-driver/mongo/options"

	"go.mongodb.org/mongo-driver/mongo"
)

type Job struct {
	// ID             primitive.ObjectID `json:"_id,omitempty" bson:"_id,omitempty"`
	Title          string `json:"Title,omitempty" bson:"Title,omitempty"`
	CompanyName    string `json:"CompanyName" bson:"CompanyName"`
	City           string `json:"City" bson:"City"`
	Country        string `json:"Country" bson:"Country"`
	CompanyLogoUrl string `json:"CompanyLogoUrl" bson:"CompanyLogoUrl"`
	JobUrl         string `json:"Url" bson:"Url"`
}

var client *mongo.Client

func getJobPostsEndpoint(response http.ResponseWriter, request *http.Request) {
	response.Header().Add("content-type", "application/json")
	var jobs []Job
	collection := client.Database("Default").Collection("AppJobs")
	ctx, _ := context.WithTimeout(context.Background(), 30*time.Second)
	cursor, err := collection.Find(ctx, bson.M{})
	if err != nil {
		response.WriteHeader(http.StatusInternalServerError)
		response.Write([]byte(`{"message": ` + err.Error() + `"}`))
		return
	}
	defer cursor.Close(ctx)
	for cursor.Next(ctx) {
		var job Job
		cursor.Decode(&job)
		fmt.Printf("%+v\n", job)
		jobs = append(jobs, job)
	}

	if err := cursor.Err(); err != nil {
		response.WriteHeader(http.StatusInternalServerError)
		response.Write([]byte(`{"message": ` + err.Error() + `"}`))
		return
	}

	json.NewEncoder(response).Encode(jobs)
}

func main() {
	fmt.Println("Starting the application ...")

	ctx, _ := context.WithTimeout(context.Background(), 10*time.Second)
	client, _ = mongo.Connect(ctx, options.Client().ApplyURI("mongodb://localhost:27017"))

	router := mux.NewRouter()
	router.HandleFunc("/jobs", getJobPostsEndpoint).Methods("GET")
	http.ListenAndServe(":12345", router)

}