tickets

3.1 KB

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