]> Cypherpunks.ru repositories - goredo.git/blob - main.go
c01ab80e10fe4b6ad232e1f8602f2499a9283dbc
[goredo.git] / main.go
1 /*
2 goredo -- redo implementation on pure Go
3 Copyright (C) 2020 Sergey Matveev <stargrave@stargrave.org>
4
5 This program is free software: you can redistribute it and/or modify
6 it under the terms of the GNU General Public License as published by
7 the Free Software Foundation, version 3 of the License.
8
9 This program is distributed in the hope that it will be useful,
10 but WITHOUT ANY WARRANTY; without even the implied warranty of
11 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
12 GNU General Public License for more details.
13
14 You should have received a copy of the GNU General Public License
15 along with this program.  If not, see <http://www.gnu.org/licenses/>.
16 */
17
18 package main
19
20 import (
21         "bufio"
22         "crypto/rand"
23         "flag"
24         "fmt"
25         "io"
26         "io/ioutil"
27         "log"
28         "os"
29         "path"
30         "path/filepath"
31         "strconv"
32
33         "go.cypherpunks.ru/recfile"
34         "golang.org/x/sys/unix"
35 )
36
37 var (
38         Cwd       string
39         BuildUUID string
40 )
41
42 func mustSetenv(key, value string) {
43         if err := os.Setenv(key, value); err != nil {
44                 panic(err)
45         }
46 }
47
48 func mustParseFd(v, name string) *os.File {
49         ptr, err := strconv.ParseUint(v, 10, 64)
50         if err != nil {
51                 panic(err)
52         }
53         fd := os.NewFile(uintptr(ptr), name)
54         if fd == nil {
55                 panic("can not parse fd: " + name)
56         }
57         return fd
58 }
59
60 func main() {
61         version := flag.Bool("version", false, "print version")
62         warranty := flag.Bool("warranty", false, "print warranty information")
63         symlinks := flag.Bool("symlinks", false, "create necessary symlinks in current direcotyr")
64
65         flag.Usage = usage
66         flag.Parse()
67         if *warranty {
68                 fmt.Println(Warranty)
69                 return
70         }
71         if *version {
72                 fmt.Println(versionGet())
73                 return
74         }
75         if *symlinks {
76                 rc := 0
77                 for _, cmdName := range []string{
78                         "redo",
79                         "redo-always",
80                         "redo-cleanup",
81                         "redo-dot",
82                         "redo-ifchange",
83                         "redo-ifcreate",
84                         "redo-log",
85                         "redo-stamp",
86                         "redo-whichdo",
87                 } {
88                         fmt.Println(os.Args[0], "<-", cmdName)
89                         if err := os.Symlink(os.Args[0], cmdName); err != nil {
90                                 rc = 1
91                                 log.Println(err)
92                         }
93                 }
94                 fmt.Println("no creating optional:", os.Args[0], "<- tai64nlocal")
95                 os.Exit(rc)
96         }
97         log.SetFlags(0)
98
99         var err error
100         Cwd, err = unix.Getwd()
101         if err != nil {
102                 panic(err)
103         }
104
105         NoColor = os.Getenv(EnvNoColor) != ""
106         NoSync = os.Getenv(EnvNoSync) == "1"
107
108         TopDir = os.Getenv(EnvTopDir)
109         if TopDir != "" {
110                 TopDir, err = filepath.Abs(TopDir)
111                 if err != nil {
112                         panic(err)
113                 }
114         }
115
116         if *flagStderrKeep {
117                 mustSetenv(EnvStderrKeep, "1")
118         }
119         if *flagStderrSilent {
120                 mustSetenv(EnvStderrSilent, "1")
121         }
122         if *flagDebug {
123                 mustSetenv(EnvDebug, "1")
124         }
125         if *flagLogWait {
126                 mustSetenv(EnvLogWait, "1")
127         }
128         if *flagLogLock {
129                 mustSetenv(EnvLogLock, "1")
130         }
131         if *flagLogPid {
132                 mustSetenv(EnvLogPid, "1")
133         }
134         if *flagLogJS {
135                 mustSetenv(EnvLogJS, "1")
136         }
137         StderrKeep = os.Getenv(EnvStderrKeep) == "1"
138         StderrSilent = os.Getenv(EnvStderrSilent) == "1"
139         Debug = os.Getenv(EnvDebug) == "1"
140         LogWait = os.Getenv(EnvLogWait) == "1"
141         LogLock = os.Getenv(EnvLogLock) == "1"
142         LogJS = os.Getenv(EnvLogJS) == "1"
143         if Debug || os.Getenv(EnvLogPid) == "1" {
144                 MyPid = os.Getpid()
145         }
146         if *flagTrace {
147                 Trace = true
148         } else {
149                 Trace = os.Getenv(EnvTrace) == "1"
150         }
151
152         // Those are internal envs
153         StderrPrefix = os.Getenv(EnvStderrPrefix)
154         if v := os.Getenv(EnvLevel); v != "" {
155                 Level, err = strconv.Atoi(v)
156                 if err != nil {
157                         panic(err)
158                 }
159                 if Level < 0 {
160                         panic("negative " + EnvLevel)
161                 }
162         }
163         var fdDep *os.File
164         if v := os.Getenv(EnvDepFd); v != "" {
165                 fdDep = mustParseFd(v, EnvDepFd)
166         }
167         BuildUUID = os.Getenv(EnvBuildUUID)
168         if BuildUUID == "" {
169                 raw := new([16]byte)
170                 if _, err = io.ReadFull(rand.Reader, raw[:]); err != nil {
171                         panic(err)
172                 }
173                 raw[6] = (raw[6] & 0x0F) | uint8(4<<4) // version 4
174                 BuildUUID = fmt.Sprintf(
175                         "%x-%x-%x-%x-%x",
176                         raw[0:4], raw[4:6], raw[6:8], raw[8:10], raw[10:],
177                 )
178         }
179
180         tgts := flag.Args()
181         if len(tgts) == 0 {
182                 tgts = []string{"all"}
183         }
184         ok := true
185         err = nil
186         cmdName := path.Base(os.Args[0])
187         trace(CDebug, "[%s] run: %s %s [%s]", BuildUUID, cmdName, tgts, Cwd)
188
189 CmdSwitch:
190         switch cmdName {
191         case "redo":
192                 for _, tgt := range tgts {
193                         ok, err = ifchange([]string{tgt}, true)
194                         if err != nil || !ok {
195                                 break
196                         }
197                 }
198         case "redo-ifchange":
199                 ok, err = ifchange(tgts, false)
200                 writeDeps(fdDep, tgts)
201         case "redo-ifcreate":
202                 if fdDep == nil {
203                         log.Fatalln("no", EnvDepFd)
204                 }
205                 for _, tgt := range tgts {
206                         err = ifcreate(fdDep, tgt)
207                         if err != nil {
208                                 break
209                         }
210                 }
211         case "redo-always":
212                 if fdDep == nil {
213                         log.Fatalln("no", EnvDepFd)
214                 }
215                 err = always(fdDep)
216         case "redo-cleanup":
217                 for _, what := range tgts {
218                         err = cleanupWalker(Cwd, what)
219                         if err != nil {
220                                 break
221                         }
222                 }
223         case "redo-dot":
224                 err = dotPrint(tgts)
225         case "redo-stamp":
226                 if fdDep == nil {
227                         log.Fatalln("no", EnvDepFd)
228                 }
229                 err = stamp(fdDep, os.Stdin)
230         case "redo-log":
231                 if len(tgts) != 1 {
232                         log.Fatalln("single target expected")
233                 }
234                 d, t := cwdAndTgt(tgts[0])
235                 var fd *os.File
236                 fd, err = os.Open(path.Join(d, RedoDir, t+LogSuffix))
237                 if err != nil {
238                         break
239                 }
240                 _, err = io.Copy(os.Stdout, fd)
241         case "redo-whichdo":
242                 if len(tgts) != 1 {
243                         log.Fatalln("single target expected")
244                 }
245                 var fdTmp *os.File
246                 fdTmp, err = ioutil.TempFile("", "")
247                 if err != nil {
248                         break
249                 }
250                 os.Remove(fdTmp.Name())
251                 var doFile string
252                 cwd, tgt := cwdAndTgt(tgts[0])
253                 doFile, _, err = findDo(fdTmp, cwd, tgt)
254                 if err != nil {
255                         break
256                 }
257                 fdTmp.Seek(0, 0)
258                 r := recfile.NewReader(fdTmp)
259                 for {
260                         m, err := r.NextMap()
261                         if err != nil {
262                                 if err == io.EOF {
263                                         break
264                                 }
265                                 break CmdSwitch
266                         }
267                         fmt.Println(cwdMustRel(cwd, m["Target"]))
268                 }
269                 ok = doFile != ""
270         case "tai64nlocal":
271                 bw := bufio.NewWriter(os.Stdout)
272                 err = tai64nLocal(bw, os.Stdin)
273                 bw.Flush()
274         default:
275                 log.Fatalln("unknown command", cmdName)
276         }
277         if err != nil {
278                 log.Println(err)
279         }
280         rc := 0
281         if !ok || err != nil {
282                 rc = 1
283         }
284         trace(CDebug, "[%s] finished: %s %s", BuildUUID, cmdName, tgts)
285         os.Exit(rc)
286 }