import mongoose from 'mongoose'
import services from '../services'
import models from '../models'
import BaseService = require('../services/core')

declare type EnvObject = {
	/** 环境名称 */
	name: string
	/** Pm2启动时cluster模式下的instanceNum */
	instanceId: number
	/** 是否为生产环境 */
	isProd: boolean
	/** 是否启用ECC验证 */
	eccEnabled: boolean
	/** 服务类型 */
	server: string
	/** 服务版本号 */
	version: string
	/** 启动模式 */
	launchMode: string
	/** 在InternalRPC中自动注册的namespace */
	rpcNamespace: string
	/** 进程类型 */
	processType: string
	/** 进程Key */
	processKey: string
	/** 进程前缀 */
	processPrefix: string
	/** 进程启动模式 */
	mode: 'app' | 'task'
	/** 进程启动参数 */
	param?: string
	/** 进程启动时指定的任务名 */
	task?: string
	/** 进程需要负责的任务内容，以,号分割 */
	jobs?: string
	/** 启动进程时若指定用最新版本，则使用这个path */
	latestNodePath?: string
	/** 进程脚本文件名，用于启动新进程 */
	script: string
	/** 主机HOST */
	host: string
	/** 默认Mongo */
	defaultMongo: string
	/** 默认Redis */
	defaultRedis: string
	/** 默认Consul地址 */
	defaultConsul: string
	/** 内部签名Secret */
	secret: string
	/** 设置后worker将自动启动, 默认true */
	autoStart: boolean
}

declare class JadepoolSingleton {
	public env: EnvObject
	/**
	 * 全局配置
	 */
	public config: {}
	/**
	 * 配置服务
	 */
	public configSrv: services.ConfigService
	/**
	 * 服务发现
	 */
	public consulSrv: services.ConsulService
	/**
	 * 活动服务
	 */
	public activitySrv: services.ActivityService
	/**
	 * 自动注册的服务
	 */
	public autoRegisterServices: string[]

	/**
	 * 注册服务
	 * @param serviceClass 
	 * @param opts 
	 */
	registerService(name: 'express', opts: services.ExpressOptions): Promise<services.ExpressService>;
	registerService(name: 'koa', opts: services.KoaOptions): Promise<services.KoaService>;
	registerService(name: 'activity', opts: any): Promise<services.ActivityService>;
	registerService(name: 'error.code', opts: services.LocaleCodeOptions): Promise<services.ErrorCodeService>;
	registerService(name: 'script', opts: services.ScriptOptions): Promise<services.ScriptService>;
	registerService(name: 'jsonrpc.server', opts: services.JSONRPCServerOptions): Promise<services.JSONRpcService>;
	registerService(name: 'jsonrpc.client', opts: services.JSONRPCOptions): Promise<services.JSONRpcClientService>;
	registerService(name: 'jsonrpc.internal', opts: services.InternalRPCOptions): Promise<services.InternalRpcService>;
	registerService(name: 'socket.io', opts: services.SocketIOOptions): Promise<services.SocketIOService>;
	registerService(name: 'socket.io.worker', opts: services.SocketIOWorkerOptions): Promise<services.SocketIOWorkerService>;
	registerService(name: 'pm2.process', opts: any): Promise<services.Pm2Service>;
	registerService(name: 'child.process', opts: any): Promise<services.ProcessService>;
	registerService(name: 'async.plan', opts: services.AsyncPlanOptions): Promise<services.AsyncPlanService>;
	registerService(name: 'config', opts: services.ConfigOptions): Promise<services.ConfigService>;
	registerService(name: 'consul', opts: services.ConsulOptions): Promise<services.ConsulService>;
	registerService(name: 'consul.kv.monitor', opts: services.ConsulKVMonitorOptions): Promise<services.ConsulKVMonitorService>;
	registerService(name: 'job.queue', opts: services.JobQueueOptions): Promise<services.JobQueueService>;
	registerService(name: 'msg.queue', opts: any): Promise<services.MsgQueueService>;
	registerService(name: 'stat', opts: any): Promise<services.StatService>;

	/**
	 * 确保服务已注册
	 * @param serviceClass 
	 * @param opts 
	 */
	ensureService(name: 'express', opts: services.ExpressOptions): Promise<services.ExpressService>;
	ensureService(name: 'koa', opts: services.KoaOptions): Promise<services.KoaService>;
	ensureService(name: 'activity', opts: any): Promise<services.ActivityService>;
	ensureService(name: 'error.code', opts: services.LocaleCodeOptions): Promise<services.ErrorCodeService>;
	ensureService(name: 'script', opts: services.ScriptOptions): Promise<services.ScriptService>;
	ensureService(name: 'jsonrpc.server', opts: services.JSONRPCServerOptions): Promise<services.JSONRpcService>;
	ensureService(name: 'jsonrpc.client', opts: services.JSONRPCOptions): Promise<services.JSONRpcClientService>;
	ensureService(name: 'jsonrpc.internal', opts: services.InternalRPCOptions): Promise<services.InternalRpcService>;
	ensureService(name: 'socket.io', opts: services.SocketIOOptions): Promise<services.SocketIOService>;
	ensureService(name: 'socket.io.worker', opts: services.SocketIOWorkerOptions): Promise<services.SocketIOWorkerService>;
	ensureService(name: 'pm2.process', opts: any): Promise<services.Pm2Service>;
	ensureService(name: 'child.process', opts: any): Promise<services.ProcessService>;
	ensureService(name: 'async.plan', opts: services.AsyncPlanOptions): Promise<services.AsyncPlanService>;
	ensureService(name: 'config', opts: services.ConfigOptions): Promise<services.ConfigService>;
	ensureService(name: 'consul', opts: services.ConsulOptions): Promise<services.ConsulService>;
	ensureService(name: 'consul.kv.monitor', opts: services.ConsulKVMonitorOptions): Promise<services.ConsulKVMonitorService>;
	ensureService(name: 'job.queue', opts: services.JobQueueOptions): Promise<services.JobQueueService>;
	ensureService(name: 'msg.queue', opts: any): Promise<services.MsgQueueService>;
	ensureService(name: 'stat', opts: any): Promise<services.StatService>;

	/**
	 * 获取服务
	 * @param name
	 */
	getService(name: 'express'): services.ExpressService;
	getService(name: 'koa'): services.KoaService;
	getService(name: 'activity'): services.ActivityService;
	getService(name: 'error.code'): services.ErrorCodeService;
	getService(name: 'script'): services.ScriptService;
	getService(name: 'jsonrpc.server'): services.JSONRpcService;
	getService(name: 'jsonrpc.client'): services.JSONRpcClientService;
	getService(name: 'jsonrpc.internal'): services.InternalRpcService;
	getService(name: 'socket.io'): services.SocketIOService;
	getService(name: 'socket.io.worker'): services.SocketIOWorkerService;
	getService(name: 'pm2.process'): services.Pm2Service;
	getService(name: 'child.process'): services.ProcessService;
	getService(name: 'async.plan'): services.AsyncPlanService;
	getService(name: 'config'): services.ConfigService;
	getService(name: 'consul'): services.ConsulService;
	getService(name: 'consul.kv.monitor'): services.ConsulKVMonitorService;
	getService(name: 'job.queue'): services.JobQueueService;
	getService(name: 'msg.queue'): services.MsgQueueService;

	/**
	 * 获取模型
	 * @param name
	 */
	getModel(name: 'app'): mongoose.Model<models.AppDocument>;
	getModel(name: 'asyncplan'): mongoose.Model<models.AsyncPlanDocument>;
	getModel(name: 'wallet'): mongoose.Model<models.WalletDocument>;
	getModel(name: 'wallet_template'): mongoose.Model<models.WalletTemplateDocument>;
	getModel(name: 'configdat'): mongoose.Model<models.ConfigDatDocument>;
	getModel(name: 'activity'): mongoose.Model<models.ActivityDocument>;
	getModel(name: string): mongoose.Model<mongoose.Document>;

	/**
	 * 获取应用信息
	 * @param id
	 */
	fetchAppConfig(id: string): Promise<models.AppDocument>;

	/**
	 * 发起async plan
	 * @param plans 计划任务
	 * @param mode 运行模式
	 * @param source 来源
	 * @param sourceId 来源id
	 * @param runAt 运行时机
	 * @param referPlan 引用plan
	 */
	createAsyncPlan(plans: models.OnePlan[], mode: 'series' | 'parallel', source: 'system' | 'admin' | 'application', sourceId?: string, runAt?: Date, referPlan?: models.AsyncPlanDocument): Promise<models.AsyncPlanDocument>

	/**
	 * 进行Methods调用
	 */
	invokeMethod(methodName: string, namespace: string | null, args: object, ...others: any): Promise<any>;

	/**
	 * 该方法是否可调用
	 * @param methodName 方法名
	 * @param namespace namespace
	 */
	invokeMethodValid(methodName: string, namespace: string | null): Promise<boolean>;
}