fakeFS support 'status' command

Author: chemax

test/fakeFS/fakeFsWorker.go

@@ -37,9 +37,18 @@ const (
 	BufLen                            = 4096
 	SerializePlain                    = 0
 	SerializeJson                     = 1
+	FSStatusReply                     = `UP %d years, %d days, %d hours, %d minutes, %d seconds, %d milliseconds, %d microseconds
+FreeSWITCH (Version 1.8.7 git 6047ebd 2019-07-02 20:06:09Z 64bit) is ready
+0 session(s) since startup
+0 session(s) - peak 0, last 5min 0
+0 session(s) per Sec out of max 30, peak 0, last 5min 0
+1000 session(s) max
+min idle cpu 0.00/99.73
+Current Stack Size/Max 240K/8192K`
 )
 
 type Worker struct {
+	startTime    time.Time
 	stop         bool
 	conn         net.Conn
 	pass         string
@@ -60,6 +69,7 @@ func NewWorker(conn net.Conn, pass, uuid string, events chan *Event) *Worker {
 		resUuid = tryUuid
 	}
 	return &Worker{
+		startTime:    time.Now(),
 		conn:         conn,
 		pass:         pass,
 		events:       make([]string, 0),
@@ -160,6 +170,17 @@ func (fs *Worker) processCommand(s string) {
 				fs.customEvents = append(fs.customEvents, events[i])
 			}
 		}
+	case "api", "bgapi":
+		var reply string
+		if args[0] == "status" {
+			Y, M, D, H, m, sec := diff(time.Now(), fs.startTime)
+			reply = fmt.Sprintf(FSStatusReply, Y, M, D, H, m, sec, 0)
+		} else {
+			reply = FsErrCommandNotFound
+		}
+		if _, err := fs.conn.Write([]byte(reply)); err != nil {
+			fs.stop = true
+		}
 	default:
 		if _, err := fs.conn.Write([]byte(FsErrCommandNotFound)); err != nil {
 			fs.stop = true
@@ -220,3 +241,50 @@ func (fs *Worker) sendMessage(buf string) error {
 	}
 	return nil
 }
+
+func diff(a, b time.Time) (year, month, day, hour, min, sec int) {
+	if a.Location() != b.Location() {
+		b = b.In(a.Location())
+	}
+	if a.After(b) {
+		a, b = b, a
+	}
+	y1, M1, d1 := a.Date()
+	y2, M2, d2 := b.Date()
+
+	h1, m1, s1 := a.Clock()
+	h2, m2, s2 := b.Clock()
+
+	year = int(y2 - y1)
+	month = int(M2 - M1)
+	day = int(d2 - d1)
+	hour = int(h2 - h1)
+	min = int(m2 - m1)
+	sec = int(s2 - s1)
+
+	// Normalize negative values
+	if sec < 0 {
+		sec += 60
+		min--
+	}
+	if min < 0 {
+		min += 60
+		hour--
+	}
+	if hour < 0 {
+		hour += 24
+		day--
+	}
+	if day < 0 {
+		// days in month:
+		t := time.Date(y1, M1, 32, 0, 0, 0, 0, time.UTC)
+		day += 32 - t.Day()
+		month--
+	}
+	if month < 0 {
+		month += 12
+		year--
+	}
+
+	return
+}