plank/index.coffee at master · pericles-project/plank · GitHub

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
express = require("express")
bodyParser = require("body-parser")

uuid = require("node-uuid")
fs = require("fs")
restler = require("restler")

PLANK_HOST = "localhost"
PLANK_PORT = process.env.PLANK_PORT or "7000"

plank = require("./lib")

app = express()

app.use bodyParser()
app.all "/handlers/:action", require "./lib/middleware/repository"
#app.use require "./lib/middleware/git-server"

# curl -H "Content-Type: application/json" -d '{"payload":{"xid":"1","xuri":"https://github.com/pericles-project/tests.git","wid":"1/0"}}' http://localhost:7000/handlers/x

queue = require("./lib/queue")

app.get "/status/:wiid?/:wstep?", (req, res, next) ->
  if req.params?.wiid?
    return res.send "Not found", 404 if not queue[req.params.wiid]
    if req.params?.wstep? and queue[req.params.wiid][req.params.wstep]
      return res.send "Not found", 404 if not queue[req.params.wiid][req.params.wstep]
      return res.send queue[req.params.wiid][req.params.wstep]
    return res.send queue[req.params.wiid]
  return res.send queue

app.post "/handlers/x", (req, res, next) ->
  console.info "[HANDLER:X] Handler triggered."
  req.state.state = "WORKING"

  newFileName = "new-file-#{uuid.v4()}.tmp"
  console.info "[HANDLER:X] Adding new file with name '#{newFileName}'..."
  setTimeout =>
    fs.appendFile "#{req.state.repo.path}/#{newFileName}", "New line or whatever...", (err) ->
      return next err if err

      console.info "[HANDLER:X] Added."
      console.info "[HANDLER:X] Committing file..."
      message = "Create new random file."
      plank.commit req.state.repo.path, newFileName, message, (err, commitId) ->
        return next err if err

        console.info "[HANDLER:X] Committed."
        req.state.commits["#{commitId}"] = message
        return next()
  , 10 * 1000

app.post "/handlers/y", (req, res, next) ->
  console.info "[HANDLER:Y] Handler triggered."
  req.state.state = "WORKING"

  setTimeout =>
    console.info "[HANDLER:Y] Adding a new line to 'README.md'..."
    fs.appendFile "#{req.state.repo.path}/README.md", "\r\nSomething happening...", (err) ->
      return next err if err

      console.info "[HANDLER:Y] Line added."
      console.info "[HANDLER:Y] Committing file..."
      message = "Modify readme file."
      plank.commit req.state.repo.path, "README.md", message, (err, commitId) ->
        return next err if err

        console.info "[HANDLER:Y] Committed."
        req.state.commits["#{commitId}"] = message
        return next()
  , 10 * 1000

app.all "/handlers/:action", require("./lib/middleware/enforcer")

app.use "/handlers/:action", require("./lib/middleware/error")

app.listen PLANK_PORT