about summary refs log blame commit diff stats
path: root/linux/312copy.subx
blob: 11bfbc3e61eebcc25a37fa259be6069601896592 (plain) (tree)



































































                                                                                                          
== code

copy-array-object:  # src: (addr array T), dest-ah: (addr handle array T)
    # . prologue
    55/push-ebp
    89/<- %ebp 4/r32/esp
    #
    (copy-array Heap *(ebp+8) *(ebp+0xc))
$copy-array-object:end:
    # . epilogue
    89/<- %esp 5/r32/ebp
    5d/pop-to-ebp
    c3/return

# create an independent copy of file src into dest
# there's no way to do this without knowing the filename
copy-file:  # src: (addr buffered-file), dest-ah: (addr handle buffered-file), filename: (addr array byte)
    # . prologue
    55/push-ebp
    89/<- %ebp 4/r32/esp
    # . save registers
    50/push-eax
    51/push-ecx
    52/push-edx
    53/push-ebx
    56/push-esi
    57/push-edi
    # esi = src
    8b/-> *(ebp+8) 6/r32/esi
    # var n/ecx: int = src->buffer->size + 16
    8b/-> *(esi+0xc) 0/r32/eax
    05/add-to-eax 0x10/imm32  # buffered-file fields before buffer contents
    89/<- %ecx 0/r32/eax
    #
    (allocate Heap %ecx *(ebp+0xc))
    # var dest/edi: (addr buffered-file) = lookup(*dest-ah)
    8b/-> *(ebp+0xc) 0/r32/eax
    (lookup *eax *(eax+4))  # => eax
    89/<- %edi 0/r32/eax
    #
    (copy-bytes %esi %edi %ecx)
    # var offset/ecx: int = lseek(src->fd, 0, SEEK_CUR)
    8b/-> *esi 3/r32/ebx
    b9/copy-to-ecx 0/imm32/offset
    ba/copy-to-edx 1/imm32/whence:SEEK_CUR
    (syscall_lseek)
    89/<- %ecx 0/r32/eax
    # at this point dest is identical to src, including file descriptor. Now
    # create an independent copy of the file descriptor
    (open-fd *(ebp+0x10) 0)  # false => eax
    89/<- *edi 0/r32/eax
    # replicate offset in the new fd
    89/<- %ebx 0/r32/eax  # fd
    51/push-ecx  # offset
    ba/copy-to-edx 0/imm32/whence:SEEK_SET
    (syscall_lseek)
$copy-file:end:
    # . restore registers
    5f/pop-to-edi
    5e/pop-to-esi
    5b/pop-to-ebx
    5a/pop-to-edx
    59/pop-to-ecx
    58/pop-to-eax
    # . epilogue
    89/<- %esp 5/r32/ebp
    5d/pop-to-ebp
    c3/return
t'>
505c5d8 ^
90638ac ^
37be25f ^

4f0847b ^
90638ac ^
37be25f ^

505c5d8 ^
90638ac ^
505c5d8 ^
505c5d8 ^

37be25f ^


505c5d8 ^
a6f47c0 ^

dec003b ^
1168570 ^
505c5d8 ^
f4eb1c7 ^
1168570 ^








df1d1ef ^
1168570 ^




dec003b ^




1168570 ^
90638ac ^
dec003b ^

a6f47c0 ^

dec003b ^
1168570 ^
dec003b ^
f4eb1c7 ^
1168570 ^












37be25f ^
37bf8b0 ^
37be25f ^




37bf8b0 ^
1168570 ^



37be25f ^
37bf8b0 ^
37be25f ^






37bf8b0 ^
1168570 ^
90638ac ^
1168570 ^

a6f47c0 ^

1168570 ^
a6f47c0 ^
1168570 ^









711012e ^
1168570 ^

1168570 ^
2b0d4a5 ^
1168570 ^



2b0d4a5 ^


1168570 ^






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
220
221
222
223
224
225
226
227
228




                       
                  
                 
                 
 
                                     





                                                           


                                                                                       

                                                                           
                                                                                



                                                
                                            









                                                             
                          




                                                               
                          

 























                                                                  


















                                                                 








                                                 


                                                    

                                
                                                   
                                                      

                                   
                                                         
                                                      

                
                                                        
                                                      
         

                                  


                                 
 

                                                      
                                               
 
                              
                       








                                                                     
                         




                                                                 




                                                 
 
                                           

                                  

                                                      
                                               
 
                              
                       












                                                             
                                    
                                                        




                                  
                                                         



                                 
                                    
                                                         






                                  
                       
 
                                           

                                  

                                                      
                                               
 









                                           
                                           

                                                         
                                                                                   
                                                                                     



                                               


                                          






                                 
package main

import (
	"crypto/sha256"
	"fmt"
	"net/http"
	"strconv"
	"strings"

	"github.com/getwtxt/registry"
	"github.com/gorilla/mux"
)

// handles "/"
func indexHandler(w http.ResponseWriter, r *http.Request) {

	pingAssets()

	etag := fmt.Sprintf("%x", sha256.Sum256([]byte(staticCache.indexMod.String())))

	// Take the hex-encoded sha256 sum of the index template's mod time
	// to send as an ETag. If an error occurred when grabbing the file info,
	// the ETag will be empty.
	w.Header().Set("ETag", "\""+etag+"\"")
	w.Header().Set("Content-Type", htmlutf8)

	_, err := w.Write(staticCache.index)
	if err != nil {
		log500(w, r, err)
		return
	}

	log200(r)
}

// handles "/api"
func apiBaseHandler(w http.ResponseWriter, r *http.Request) {
	indexHandler(w, r)
}

// handles "/api/plain"
// maybe add json/xml support later
func apiFormatHandler(w http.ResponseWriter, r *http.Request) {
	indexHandler(w, r)
}

func apiAllTweetsHandler(w http.ResponseWriter, r *http.Request) {
	out, err := twtxtCache.QueryAllStatuses()
	if err != nil {
		log500(w, r, err)
	}

	data := parseQueryOut(out)
	if err != nil {
		data = []byte("")
	}

	etag := fmt.Sprintf("%x", sha256.Sum256(data))
	w.Header().Set("ETag", etag)
	w.Header().Set("Content-Type", txtutf8)

	_, err = w.Write(data)
	if err != nil {
		log500(w, r, err)
		return
	}

	log200(r)
}

// handles "/api/plain/(users|mentions|tweets)"
func apiEndpointHandler(w http.ResponseWriter, r *http.Request) {

	err := r.ParseForm()
	if err != nil {
		log500(w, r, err)
		return
	}

	if r.FormValue("q") != "" || r.FormValue("url") != "" {
		err := apiEndpointQuery(w, r)
		if err != nil {
			log500(w, r, err)
			return
		}
		log200(r)
		return
	}

	page := 1
	pageVal := r.FormValue("page")
	if pageVal != "" {
		page, err = strconv.Atoi(pageVal)
		if err != nil || page == 0 {
			page = 1
		}
	}

	// if there's no query, return everything in
	// registry for a given endpoint
	var out []string
	switch r.URL.Path {
	case "/api/plain/users":
		out, err = twtxtCache.QueryUser("")
		out = registry.ReduceToPage(page, out)

	case "/api/plain/mentions":
		out, err = twtxtCache.QueryInStatus("@<")
		out = registry.ReduceToPage(page, out)

	default:
		out, err = twtxtCache.QueryAllStatuses()
		out = registry.ReduceToPage(page, out)
	}

	data := parseQueryOut(out)
	if err != nil {
		data = []byte("")
	}

	etag := fmt.Sprintf("%x", sha256.Sum256(data))
	w.Header().Set("ETag", etag)
	w.Header().Set("Content-Type", txtutf8)

	_, err = w.Write(data)
	if err != nil {
		log500(w, r, err)
		return
	}

	log200(r)
}

// handles POST for "/api/plain/users"
func apiEndpointPOSTHandler(w http.ResponseWriter, r *http.Request) {
	apiPostUser(w, r)
}

// handles "/api/plain/tags"
func apiTagsBaseHandler(w http.ResponseWriter, r *http.Request) {

	out, err := twtxtCache.QueryInStatus("#")
	if err != nil {
		log500(w, r, err)
		return
	}

	out = registry.ReduceToPage(1, out)
	data := parseQueryOut(out)

	etag := fmt.Sprintf("%x", sha256.Sum256(data))
	w.Header().Set("ETag", etag)
	w.Header().Set("Content-Type", txtutf8)

	_, err = w.Write(data)
	if err != nil {
		log500(w, r, err)
		return
	}

	log200(r)
}

// handles "/api/plain/tags/[a-zA-Z0-9]+"
func apiTagsHandler(w http.ResponseWriter, r *http.Request) {

	vars := mux.Vars(r)
	tags := vars["tags"]

	tags = strings.ToLower(tags)
	out, err := twtxtCache.QueryInStatus("#" + tags)
	if err != nil {
		log500(w, r, err)
		return
	}
	tags = strings.Title(tags)
	out2, err := twtxtCache.QueryInStatus("#" + tags)
	if err != nil {
		log500(w, r, err)
		return
	}
	tags = strings.ToUpper(tags)
	out3, err := twtxtCache.QueryInStatus("#" + tags)
	if err != nil {
		log500(w, r, err)
		return
	}

	out = append(out, out2...)
	out = append(out, out3...)
	out = uniq(out)

	out = registry.ReduceToPage(1, out)
	data := parseQueryOut(out)

	etag := fmt.Sprintf("%x", sha256.Sum256(data))
	w.Header().Set("ETag", etag)
	w.Header().Set("Content-Type", txtutf8)

	_, err = w.Write(data)
	if err != nil {
		log500(w, r, err)
		return
	}

	log200(r)
}

// Serving the stylesheet virtually because
// files aren't served directly in getwtxt.
func cssHandler(w http.ResponseWriter, r *http.Request) {

	// Sending the sha256 sum of the modtime in hexadecimal for the ETag header
	etag := fmt.Sprintf("%x", sha256.Sum256([]byte(staticCache.cssMod.String())))

	w.Header().Set("ETag", "\""+etag+"\"")
	w.Header().Set("Content-Type", cssutf8)

	pingAssets()

	n, err := w.Write(staticCache.css)
	if err != nil || n == 0 {
		log500(w, r, err)
		return
	}

	log200(r)
}