tickets

2.9 KB

1. // import.hl — import AntColony ticket files into the RUNNING app, over its JSON API.
2. //
3. // bin/hybriel import.hl
4. // TICKETS_IMPORT_DIR=/some/dir TICKETS_URL=http://127.0.0.1:8350 bin/hybriel import.hl
5. //
6. // WRITES NEED A TOKEN (ticket #7): TICKETS_TOKEN = an API token (log in with ident, /you →
7. // "Create a token"); the imported tickets are opened by that token's user.
8. //
9. // A ticket file is `project:` and `subject:` header lines, a blank line, the summary
10. // (hard-wrapped lines are joined into paragraphs, blank line = new paragraph —
11. // ticketfile.hl).
12. // Each file is POSTed to /api/tickets with `source` = its file name; the app answers a
13. // known source with the ticket it already has (200, existed) instead of a second one
14. // (201), so running this twice imports nothing twice. Going through the API (not the
15. // tables) means the running server stays the only writer and open browsers see the
16. // imported tickets arrive live.
17. import { listDir, readFile } from 'hl:fs'
18. import { env } from 'hl:proc'
19. import { fetch } from 'hl:fetch'
20. import { parse } from './ticketfile.hl'
22. static dir = env('TICKETS_IMPORT_DIR') != null ? env('TICKETS_IMPORT_DIR') : './import/tickets'
23. static base = env('TICKETS_URL') != null ? env('TICKETS_URL') : 'http://127.0.0.1:8350'
24. static token = env('TICKETS_TOKEN') != null ? env('TICKETS_TOKEN') : ''
25. if (token == '') { console.log('import: TICKETS_TOKEN is not set — API writes need a token (log in, /you → Create a token)') }
27. // a > b for two strings (strings order by code point, hybriel#2; still no list sort())
28. static after = (a, b) => { return a > b }
30. // file names, sorted, so an empty store numbers each project's tickets in file order
31. names = []
32. for (n of listDir(dir)) {
33. let name = hlTypeName(n) == 'String' ? n : n.name
34. if (name.endsWith('.md')) { names.push(name) }
35. }
36. let i = 1
37. while (i < names.length) {
38. let cur = names[i]
39. let j = i - 1
40. while (j >= 0 && after(names[j], cur)) {
41. names[j + 1] = names[j]
42. j = j - 1
43. }
44. names[j + 1] = cur
45. i = i + 1
46. }
48. created = 0
49. existed = 0
50. failed = 0
51. for (name of names) {
52. let t = parse(readFile(dir + '/' + name))
53. if (t.error != null) {
54. console.log('SKIP ' + name + ': ' + t.error)
55. failed = failed + 1
56. } else {
57. let res = fetch(base + '/api/tickets', { method = 'POST' headers = { authorization = 'Bearer ' + token } json = { project = t.project subject = t.subject summary = t.summary source = name } })
58. if (res.status == 201) {
59. created = created + 1
60. let tk = res.json().ticket
61. console.log('NEW ' + name + ' → ' + tk.project + ' ' + tk.ref)
62. } else if (res.status == 200) {
63. existed = existed + 1
64. let tk = res.json().ticket
65. console.log('HAVE ' + name + ' = ' + tk.project + ' ' + tk.ref)
66. } else {
67. failed = failed + 1
68. console.log('FAIL ' + name + ': ' + res.status + ' ' + res.text())
69. }
70. }
71. }
72. console.log('import: ' + created + ' new, ' + existed + ' already there, ' + failed + ' failed (' + dir + ' → ' + base + ')')