summary refs log tree commit diff stats
path: root/pkg
diff options
context:
space:
mode:
authorAndinus <andinus@inventati.org>2020-03-14 19:10:01 +0530
committerAndinus <andinus@inventati.org>2020-03-14 19:10:01 +0530
commit50871fcd3f7698b5d3b68518aea12d31533c5c20 (patch)
treec547b1932a3422e5372d4b4f422d4628000b6cbb /pkg
parenta7e66bc241524caf1accf02966c76f436fa19210 (diff)
downloadcetus-50871fcd3f7698b5d3b68518aea12d31533c5c20.tar.gz
Add cetus-nasa program v0.4.0
cetus-nasa uses NASA's API to get Astronomy Picture of the Day.
Diffstat (limited to 'pkg')
-rw-r--r--pkg/nasa/apod.go109
1 files changed, 109 insertions, 0 deletions
diff --git a/pkg/nasa/apod.go b/pkg/nasa/apod.go
new file mode 100644
index 0000000..62eea96
--- /dev/null
+++ b/pkg/nasa/apod.go
@@ -0,0 +1,109 @@
+// Copyright (c) 2020, Andinus <andinus@inventati.org>
+
+// Permission to use, copy, modify, and/or distribute this software for any
+// purpose with or without fee is hereby granted, provided that the above
+// copyright notice and this permission notice appear in all copies.
+
+// THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
+// WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
+// MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
+// ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
+// WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
+// ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
+// OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
+
+package nasa
+
+import (
+	"encoding/json"
+	"fmt"
+	"io/ioutil"
+	"math/rand"
+	"net/http"
+	"regexp"
+	"time"
+)
+
+// APOD holds responses
+type APOD struct {
+	Copyright      string `json:"copyright"`
+	Date           string `json:"date"`
+	Explanation    string `json:"explanation"`
+	HDURL          string `json:"hdurl"`
+	MediaType      string `json:"media_type"`
+	ServiceVersion string `json:"service_version"`
+	Title          string `json:"title"`
+	URL            string `json:"url"`
+
+	Code int    `json:"code"`
+	Msg  string `json:"msg"`
+}
+
+// RandDate returns a random date between 1995-06-16 & today
+func RandDate() string {
+	var (
+		min   int64
+		max   int64
+		sec   int64
+		delta int64
+		date  string
+	)
+	min = time.Date(1995, 6, 16, 0, 0, 0, 0, time.UTC).Unix()
+	max = time.Now().UTC().Unix()
+	delta = max - min
+
+	sec = rand.Int63n(delta) + min
+	date = time.Unix(sec, 0).Format("2006-01-02")
+
+	return date
+}
+
+// APODPath returns Astronomy Picture of the Day path
+func APODPath(apodInfo map[string]string, timeout time.Duration) (APOD, error) {
+	var err error
+	apodRes := APOD{}
+
+	// validate date
+	re := regexp.MustCompile("((19|20)\\d\\d)-(0?[1-9]|1[012])-(0?[1-9]|[12][0-9]|3[01])")
+	if !re.MatchString(apodInfo["date"]) {
+		return apodRes, fmt.Errorf("%s does not match format 'YYYY-MM-DD'", apodInfo["date"])
+	}
+
+	client := http.Client{
+		Timeout: time.Second * timeout,
+	}
+
+	req, err := http.NewRequest(http.MethodGet, apodInfo["api"], nil)
+	if err != nil {
+		return apodRes, err
+	}
+	q := req.URL.Query()
+	q.Add("api_key", apodInfo["apiKey"])
+	q.Add("date", apodInfo["date"])
+	req.URL.RawQuery = q.Encode()
+
+	res, err := client.Do(req)
+
+	if err != nil {
+		fmt.Printf("Error: GET %s\n", apodInfo["api"])
+		return apodRes, err
+	}
+	defer res.Body.Close()
+
+	resBody, err := ioutil.ReadAll(res.Body)
+	if err != nil {
+		return apodRes, err
+	}
+
+	err = json.Unmarshal([]byte(resBody), &apodRes)
+	if err != nil {
+		return apodRes, err
+	}
+
+	if res.StatusCode != 200 {
+		return apodRes, fmt.Errorf("Unexpected response status code received: %d %s",
+			res.StatusCode, http.StatusText(res.StatusCode))
+	}
+
+	return apodRes, err
+}
=0.5.1&id=2dc436555d8bfa6f2409173d87cd0fec2b2385cf'>2dc4365 ^
c286d3d ^
589db74 ^



c286d3d ^
b76deea ^
0911cd5 ^
24dfc47 ^
589db74 ^
2349b7d ^
fcdcd32 ^
0f8b7a1 ^

24dfc47 ^
589db74 ^








0911cd5 ^


0911cd5 ^
24dfc47 ^

589db74 ^
0911cd5 ^
24dfc47 ^
0911cd5 ^

a15ea01 ^
2dc4365 ^


a15ea01 ^









17bd2dc ^



475b697 ^







62946ff ^
24dfc47 ^
62946ff ^

607ece8 ^
1228448 ^


648ca98 ^
b76deea ^


648ca98 ^








c286d3d ^
589db74 ^

c286d3d ^
2349b7d ^

5de1bb8 ^
2349b7d ^
589db74 ^
cf66462 ^



77c76ba ^
cf66462 ^








589db74 ^
cf66462 ^
2349b7d ^

b60999c ^




24daef8 ^



753adb9 ^











b60999c ^
b389647 ^



4ec7f5d ^








b389647 ^




026e8a1 ^





b389647 ^

5090a4c ^


0abafa6 ^
5090a4c ^


b389647 ^
5090a4c ^


312a53e ^
5090a4c ^


b389647 ^

589db74 ^
2958579 ^
b389647 ^
b60999c ^
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219


               
             
             

                                  
 




                                               


                         








                                              

 
                                                                        
                                                        


                                                
                                 
                                                      

                                    
 
                                                            
                       

                                                                      
                                    



                                       
                 
         
 
                                                         
                                                               
 
                                               

                                       
                             








                                                              


                               
 

                                                              
                                       
 
                   

 
                                      


                               









                                                     



                                                                







                                                 
                                        
                             

 
                                                   


                                   
                                                                         


                                                    








                                                
 

                                            
 

                                                             
                           
                         
                                                           



                                                             
                                                              








                                                         
                                                         
                  

         




                                                       



                                                  











                                                               
                                                             



                                                  








                                                                                               




                                                              





                                                                     

                                      


                                                                           
                                


                                                                           
                                


                                                                           
                                    


                                                                           

                                                   
                                                                  
                                                                 
         
 
package widgets

import (
	"fmt"
	"log"

	"github.com/gdamore/tcell"

	"git.sr.ht/~sircmpwn/aerc/config"
	"git.sr.ht/~sircmpwn/aerc/lib"
	"git.sr.ht/~sircmpwn/aerc/lib/ui"
	"git.sr.ht/~sircmpwn/aerc/worker"
	"git.sr.ht/~sircmpwn/aerc/worker/types"
)

type AccountView struct {
	acct      *config.AccountConfig
	conf      *config.AercConfig
	dirlist   *DirectoryList
	grid      *ui.Grid
	host      TabHost
	logger    *log.Logger
	msglist   *MessageList
	msgStores map[string]*lib.MessageStore
	worker    *types.Worker
}

func NewAccountView(conf *config.AercConfig, acct *config.AccountConfig,
	logger *log.Logger, host TabHost) *AccountView {

	grid := ui.NewGrid().Rows([]ui.GridSpec{
		{ui.SIZE_WEIGHT, 1},
	}).Columns([]ui.GridSpec{
		{ui.SIZE_EXACT, conf.Ui.SidebarWidth},
		{ui.SIZE_WEIGHT, 1},
	})

	worker, err := worker.NewWorker(acct.Source, logger)
	if err != nil {
		host.SetStatus(fmt.Sprintf("%s: %s", acct.Name, err)).
			Color(tcell.ColorDefault, tcell.ColorRed)
		return &AccountView{
			acct:   acct,
			grid:   grid,
			host:   host,
			logger: logger,
		}
	}

	dirlist := NewDirectoryList(acct, logger, worker)
	grid.AddChild(ui.NewBordered(dirlist, ui.BORDER_RIGHT))

	msglist := NewMessageList(conf, logger)
	grid.AddChild(msglist).At(0, 1)

	view := &AccountView{
		acct:      acct,
		conf:      conf,
		dirlist:   dirlist,
		grid:      grid,
		host:      host,
		logger:    logger,
		msglist:   msglist,
		msgStores: make(map[string]*lib.MessageStore),
		worker:    worker,
	}

	go worker.Backend.Run()

	worker.PostAction(&types.Configure{Config: acct}, nil)
	worker.PostAction(&types.Connect{}, view.connected)
	host.SetStatus("Connecting...")

	return view
}

func (acct *AccountView) Tick() bool {
	if acct.worker == nil {
		return false
	}
	select {
	case msg := <-acct.worker.Messages:
		msg = acct.worker.ProcessMessage(msg)
		acct.onMessage(msg)
		return true
	default:
		return false
	}
}

func (acct *AccountView) AccountConfig() *config.AccountConfig {
	return acct.acct
}

func (acct *AccountView) Worker() *types.Worker {
	return acct.worker
}

func (acct *AccountView) Logger() *log.Logger {
	return acct.logger
}

func (acct *AccountView) Name() string {
	return acct.acct.Name
}

func (acct *AccountView) Children() []ui.Drawable {
	return acct.grid.Children()
}

func (acct *AccountView) OnInvalidate(onInvalidate func(d ui.Drawable)) {
	acct.grid.OnInvalidate(func(_ ui.Drawable) {
		onInvalidate(acct)
	})
}

func (acct *AccountView) Invalidate() {
	acct.grid.Invalidate()
}

func (acct *AccountView) Draw(ctx *ui.Context) {
	acct.grid.Draw(ctx)
}

func (acct *AccountView) Focus(focus bool) {
	// TODO: Unfocus children I guess
}

func (acct *AccountView) connected(msg types.WorkerMessage) {
	switch msg.(type) {
	case *types.Done:
		acct.host.SetStatus("Listing mailboxes...")
		acct.logger.Println("Listing mailboxes...")
		acct.dirlist.UpdateList(func(dirs []string) {
			var dir string
			for _, _dir := range dirs {
				if _dir == acct.acct.Default {
					dir = _dir
					break
				}
			}
			if dir == "" {
				dir = dirs[0]
			}
			acct.dirlist.Select(dir)
			acct.logger.Println("Connected.")
			acct.host.SetStatus("Connected.")
		})
	}
}

func (acct *AccountView) Directories() *DirectoryList {
	return acct.dirlist
}

func (acct *AccountView) Messages() *MessageList {
	return acct.msglist
}

func (acct *AccountView) Store() *lib.MessageStore {
	return acct.msglist.Store()
}

func (acct *AccountView) SelectedMessage() *types.MessageInfo {
	return acct.msglist.Selected()
}

func (acct *AccountView) SelectedAccount() *AccountView {
	return acct
}

func (acct *AccountView) onMessage(msg types.WorkerMessage) {
	switch msg := msg.(type) {
	case *types.Done:
		switch msg.InResponseTo().(type) {
		case *types.OpenDirectory:
			if store, ok := acct.msgStores[acct.dirlist.selected]; ok {
				// If we've opened this dir before, we can re-render it from
				// memory while we wait for the update and the UI feels
				// snappier. If not, we'll unset the store and show the spinner
				// while we download the UID list.
				acct.msglist.SetStore(store)
			} else {
				acct.msglist.SetStore(nil)
			}
		}
	case *types.DirectoryInfo:
		if store, ok := acct.msgStores[msg.Name]; ok {
			store.Update(msg)
		} else {
			store = lib.NewMessageStore(acct.worker, msg)
			acct.msgStores[msg.Name] = store
			store.OnUpdate(func(_ *lib.MessageStore) {
				store.OnUpdate(nil)
				acct.msglist.SetStore(store)
			})
		}
	case *types.DirectoryContents:
		if store, ok := acct.msgStores[acct.dirlist.selected]; ok {
			store.Update(msg)
		}
	case *types.FullMessage:
		if store, ok := acct.msgStores[acct.dirlist.selected]; ok {
			store.Update(msg)
		}
	case *types.MessageInfo:
		if store, ok := acct.msgStores[acct.dirlist.selected]; ok {
			store.Update(msg)
		}
	case *types.MessagesDeleted:
		if store, ok := acct.msgStores[acct.dirlist.selected]; ok {
			store.Update(msg)
		}
	case *types.Error:
		acct.logger.Printf("%v", msg.Error)
		acct.host.SetStatus(fmt.Sprintf("%v", msg.Error)).
			Color(tcell.ColorDefault, tcell.ColorRed)
	}
}