Function init

plugin/minecraftobserver/minecraftobserver.go:41–231

()

)

func init() {
	// 状态查询
	engine.OnRegex("^[mM][cC]服务器状态 (.+)$").SetBlock(true).Handle(func(ctx *zero.Ctx) {
		// 关键词查找
		addr := ctx.State["regex_matched"].([]string)[1]
		resp, err := getMinecraftServerStatus(addr)
		if err != nil {
			ctx.Send(message.Text("服务器状态获取失败... 错误信息: ", err))
			return
		}
		status := resp.genServerSubscribeSchema(addr, 0)
		textMsg, iconBase64 := status.generateServerStatusMsg()
		var msg message.Message
		if iconBase64 != "" {
			msg = append(msg, message.Image(iconBase64))
		}
		msg = append(msg, message.Text(textMsg))
		if id := ctx.Send(msg); id.ID() == 0 {
			// logrus.Errorln(logPrefix + "Send failed")
			return
		}
	})
	// 添加订阅
	engine.OnRegex(`^[mM][cC]服务器添加订阅\s*(.+)$`, getDB).SetBlock(true).Handle(func(ctx *zero.Ctx) {
		// 关键词查找
		addr := ctx.State["regex_matched"].([]string)[1]
		status, err := getMinecraftServerStatus(addr)
		if err != nil {
			ctx.Send(message.Text("服务器信息初始化失败，请检查服务器是否可用！\n错误信息: ", err))
			return
		}
		targetID, targetType := warpTargetIDAndType(ctx.Event.GroupID, ctx.Event.UserID)
		err = dbInstance.newSubscribe(addr, targetID, targetType)
		if err != nil {
			ctx.Send(message.Text("订阅添加失败... 错误信息: ", err))
			return
		}
		// 插入数据库（首条，需要更新状态）
		err = dbInstance.updateServerStatus(status.genServerSubscribeSchema(addr, 0))
		if err != nil {
			ctx.Send(message.Text("服务器状态更新失败... 错误信息: ", err))
			return
		}
		if sid := ctx.Send(message.Text(fmt.Sprintf("服务器 %s 订阅添加成功", addr))); sid.ID() == 0 {
			// logrus.Errorln(logPrefix + "Send failed")
			return
		}
		// 成功后立即发送一次状态
		textMsg, iconBase64 := status.genServerSubscribeSchema(addr, 0).generateServerStatusMsg()
		var msg message.Message
		if iconBase64 != "" {
			msg = append(msg, message.Image(iconBase64))
		}
		msg = append(msg, message.Text(textMsg))
		if id := ctx.Send(msg); id.ID() == 0 {
			// logrus.Errorln(logPrefix + "Send failed")
			return
		}