Implemented manifest reader

Author: maxchehab

.gitignore

@@ -1,2 +1,3 @@
-dist
-test
+dist/
+test/
+.vscode

src/constants.go

@@ -0,0 +1,3 @@
+package main
+
+const userAgent = "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/60.0.3112.113 Safari/537.36"

src/main.go

@@ -1,5 +1,16 @@
 package main
 
+import (
+	"fmt"
+)
+
 func main() {
-	watch("./test", GetSession())
+	// session := GetSessionWithCredentials(TEST_USERNAME, TEST_PASSWORD)
+	manifest, err := RetreiveManifestFromReddit("77346c3e708a")
+
+	if err != nil {
+		fmt.Println("error: ", err)
+	} else {
+		fmt.Printf("%+v\n", manifest)
+	}
 }

src/manifest.go

@@ -0,0 +1,87 @@
+package main
+
+import (
+	"encoding/json"
+	"errors"
+	"fmt"
+	"io/ioutil"
+	"net/http"
+)
+
+// Manifest data structure describing the location of a file
+// {
+// 	"files": [
+// 	  {
+// 		"name": "test.txt",
+// 		"path": [
+// 		  "7zp1o6"
+// 		]
+// 	  }
+// 	]
+// }
+type Manifest struct {
+	Files []struct {
+		Name string   `json:"name"`
+		Path []string `json:"path"`
+	} `json:"files"`
+}
+
+// CreateManifestFromByteArray creates a Manifest object from a byte array
+func CreateManifestFromByteArray(JSON []byte) (Manifest, error) {
+	var m Manifest
+	err := json.Unmarshal(JSON, &m)
+
+	return m, err
+}
+
+// CreateManifestFromString creates a manifest object from a JSON string
+func CreateManifestFromString(JSON string) (Manifest, error) {
+	var m Manifest
+	err := json.Unmarshal([]byte(JSON), &m)
+
+	return m, err
+}
+
+// RetreiveManifestFromReddit will download a manifest from a specified subreddit
+func RetreiveManifestFromReddit(subreddit string) (Manifest, error) {
+	// https://www.reddit.com/r/[repo]/search.json?q=manifest.json&restrict_sr=on&sort=relevance&t=all
+	var m Manifest
+	url := fmt.Sprintf(`https://www.reddit.com/r/%v/search.json?q=manifest&restrict_sr=on&sort=relevance&t=all`, subreddit)
+
+	// response, err := client.Get(request)
+	request, err := http.NewRequest("GET", url, nil)
+	if err != nil {
+		return m, err
+	}
+	request.Header.Set("User-Agent", userAgent)
+	client := &http.Client{}
+
+	response, err := client.Do(request)
+	if err != nil {
+		return m, err
+	}
+	defer response.Body.Close()
+
+	if response.StatusCode != http.StatusOK {
+		fmt.Println(request)
+		return m, fmt.Errorf(`bad status code, [%v]`, response.StatusCode)
+	}
+
+	JSON, err := ioutil.ReadAll(response.Body)
+	if err != nil {
+		return m, err
+	}
+
+	search, err := CreateSearchFromByteArray(JSON)
+	if len(search.Data.Children) == 0 {
+		return m, errors.New("could not locate manifest.json")
+	}
+
+	for _, listing := range search.Data.Children {
+		if listing.Data.Subreddit == subreddit && listing.Data.Title == "manifest.json" {
+			return CreateManifestFromString(listing.Data.Text)
+		}
+	}
+
+	return m, errors.New("could not locate manifest.json")
+}

src/search.go

@@ -0,0 +1,57 @@
+package main
+
+import "encoding/json"
+
+// Search data structure describing the results of a subreddit search
+// {
+// 	"data": {
+// 	  "children": [
+// 		{
+// 		  "kind": "t3",
+// 		  "data": {
+// 			"subreddit": "77346c3e708a",
+// 			"selftext": "test",
+// 			"id": "7zpvqn",
+// 			"author": "Senior-Jesticle",
+// 			"score": 1,
+// 			"name": "t3_7zpvqn",
+// 			"url": "https://www.reddit.com/r/77346c3e708a/comments/7zpvqn/manifestjson/",
+// 			"title": "manifest.json"
+// 		  }
+// 		}
+// 	  ]
+// 	}
+// }
+type Search struct {
+	Data struct {
+		Children []struct {
+			Kind string `json:"kind"`
+			Data struct {
+				Subreddit string `json:"subreddit"`
+				Text      string `json:"selftext"`
+				ID        string `json:"id"`
+				Author    string `json:"author"`
+				Score     int    `json:"score"`
+				Name      string `json:"name"`
+				URL       string `json:"url"`
+				Title     string `json:"title"`
+			} `json:"data"`
+		} `json:"children"`
+	} `json:"data"`
+}
+
+// CreateSearchFromByteArray creates a Search object from a byte array
+func CreateSearchFromByteArray(JSON []byte) (Search, error) {
+	var s Search
+	err := json.Unmarshal(JSON, &s)
+
+	return s, err
+}
+
+// CreateSearchFromJSON creates a Search object from a JSON string
+func CreateSearchFromJSON(JSON string) (Search, error) {
+	var s Search
+	err := json.Unmarshal([]byte(JSON), &s)
+
+	return s, err
+}

src/session.go

@@ -29,3 +29,25 @@ func GetSession() *geddit.OAuthSession {
 
 	return session
 }
+
+// GetSessionWithCredentials creates geddit session with provided credentials
+func GetSessionWithCredentials(username string, password string) *geddit.OAuthSession {
+	session, err := geddit.NewOAuthSession(
+		"gNl1rziyJUjwNQ",
+		"TdeaiSX6FaxwBsfpi9L6FxFu288",
+		"redditfs",
+		"http://maxchehab.com",
+	)
+
+	if err != nil {
+		log.Fatal(err)
+	}
+
+	// Create new auth token for confidential clients (personal scripts/apps).
+	err = session.LoginAuth(username, password)
+	if err != nil {
+		log.Fatal(err)
+	}
+
+	return session
+}

src/upload.go

@@ -2,15 +2,18 @@ package main
 
 import "github.com/maxchehab/geddit"
 
-func remove(file string, session *geddit.OAuthSession) {
+// Remove deletes a file from reddit
+func Remove(file string, session *geddit.OAuthSession) {
 
 }
 
-func create(file string, session *geddit.OAuthSession) {
+// Create uploads a file from reddit
+func Create(file string, session *geddit.OAuthSession) {
 	session.Submit(geddit.NewTextSubmission("77346c3e708a", "title", "hello world", false, nil))
 
 }
 
-func change(file string, session *geddit.OAuthSession) {
+// Change edits a file from reddit
+func Change(file string, session *geddit.OAuthSession) {
 	session.EditUserText(geddit.NewEdit("this is an edit", "t3_7pni8t"))
 }