add skynet meta

Author: Gowa2017

meta/3rd/skynet/config.lua

@@ -0,0 +1 @@
+words = { "skynet.start" }

meta/3rd/skynet/library/skynet.lua

@@ -0,0 +1,52 @@
+---@meta
+---* cluster 相关的库
+---* 这个库，使用了一个叫 clusterd 的服务来进行工作
+---@class cluster
+local cluster = {}
+
+---* 对某个节点上的服务传输消息
+---@param node string @配置中给出的节点名
+---@param address string | number @推荐使用 . 开头本地服务名，因为没有必要再用 master/slave 模式
+---@varargs any @传输数据
+function cluster.call(node, address, ...)
+end
+---* 对某个节点上的服务传输消息
+---* 越节点推送消息有丢失消息的风险。因为 cluster 基于 tcp 连接，当 cluster 间的连接断开，cluster.send 的消息就可能丢失。而这个函数会立刻返回，所以调用者没有机会知道发送出错。
+---@param node string @配置中给出的节点名
+---@param address string | number @推荐使用 . 开头本地服务名，因为没有必要再用 master/slave 模式
+---@varargs any @传输数据
+function cluster.send(node, address, ...)
+end
+---* 打开节点
+---* 如果参数是一个节点名，那么会从配置文件中加载的名称对应的IP和端口进行监听
+---* 实际上就是开了一个 gate 服务，监听套接字
+---@param port string | number @节点名或者是端口号
+function cluster.open(port)
+end
+---* 重新加载节点配置信息
+---* Cluster 是去中心化的，所以需要在每台机器上都放置一份配置文件（通常是相同的）。
+---* 通过调用 cluster.reload 可以让本进程重新加载配置。
+---* 如果你修改了每个节点名字对应的地址，那么 reload 之后的请求都会发到新的地址。
+---* 而之前没有收到回应的请求还是会在老地址上等待。如果你老的地址已经无效（通常是主动关闭了进程）那么请求方会收到一个错误。
+---@param config table @ 名称=IP:端口键值对
+function cluster.reload(config)
+end
+---* 为某个节点上的服务生成一个代理服务 clusterproxy
+---@param node string
+---@param name string
+function cluster.proxy(node, name)
+end
+function cluster.snax(node, name, address)
+end
+---* 可以把 addr 注册为 cluster 可见的一个字符串名字 name 。如果不传 addr 表示把自身注册为 name 。
+---@param name string
+---@param addr number
+function cluster.register(name, addr)
+end
+---* 查询节点上服务的地址
+---@param node string
+---@param name string
+---@return number
+function cluster.query(node, name)
+end
+return cluster

meta/3rd/skynet/library/skynet/cluster.lua

@@ -0,0 +1,90 @@
+---@meta
+---@class crypt
+local crypt = {}
+
+---计算 hash
+---@param key any
+---@return string
+function crypt.hashkey(key)
+end
+---生成一个8位的 key
+---@return string
+function crypt.randomkey()
+end
+---des 加密
+---@param key number
+---@param data string
+---@param padding number | nil @对齐模式 默认 iso7816_4
+---@return string
+function crypt.desencode(key, data, padding)
+end
+---desc 解密
+---@param key number
+---@param data string
+---@param padding number | nil @对齐模式 默认 iso7816_4
+---@return string
+function crypt.desdecode(key, data, padding)
+end
+---hex 编码
+---@param data string
+---@return string
+function crypt.hexencode(data)
+end
+---hex 解码
+---@param data string
+---@return string
+function crypt.hexdecode(data)
+end
+---hmac 签名
+---@param challenge string @挑战消息
+---@param secret string @密钥
+---@return string
+function crypt.hmac64(challenge, secret)
+end
+---hmac md5签名
+---@param msg string
+---@param secret string
+---@return string
+function crypt.hmac64_md5(msg, secret)
+end
+---dh交换
+---@param key string
+---@return string
+function crypt.dhexchange(key)
+end
+---密钥计算
+---@param dhkey string @经过 exchange 后的密钥
+---@param selfkey string @原始
+function crypt.dhsecret(dhkey, selfkey)
+end
+---base64编码
+---@param msg string
+---@return string
+function crypt.base64encode(msg)
+end
+---base64解码
+---@param msg string
+---@return string
+function crypt.base64decode(msg)
+end
+---sha1
+---@param msg string
+---@return string
+function crypt.sha1(msg)
+end
+function crypt.hmac_sha1()
+end
+---hmac hash
+---@param key string
+---@param msg string
+---@return string
+function crypt.hmac_hash(key, msg)
+end
+---xor 字符串
+---@param s1 string
+---@param key string
+---@return lightuserdata
+function crypt.xor_str(s1, key)
+end
+
+return crypt

meta/3rd/skynet/library/skynet/crypt.lua

@@ -0,0 +1,207 @@
+---@meta
+local mongo = {}
+
+---@class mongo_client
+---@field host string
+---@field port number
+---@field username string
+---@field password string
+---@field authdb string
+---@field authmod string
+---@field __id number
+---@field __sock socketchannel
+local mongo_client = {}
+
+---@class mongo_db
+---@field connection mongo_client
+---@field name string 
+---@field full_name string
+---@field database mongo_db
+---@field _cmd string dbname.$cmd
+local mongo_db = {}
+
+---@class mongo_collection
+---@field connection mongo_client
+---@field name string
+---@field full_name string
+---@field database boolean
+local mongo_collection = {}
+
+---@class mongo_cursor
+local mongo_cursor = {}
+---建立一个客户端
+---@param conf table {host, port, username, password, authdb, authmod}
+---@return mongo_client
+function mongo.client(conf)
+end
+---获取一个 mongo_db 对象
+---@param dbname string
+---@return mongo_db
+function mongo_client:getDB(dbname)
+end
+
+---断开连接
+function mongo_client:disconnect()
+end
+---以 self.admin:runCommand(...) 来执行命令
+function mongo_client:runCommand(...)
+end
+
+---退出登录
+function mongo_client:logout()
+end
+
+---验证登录
+---@param user string
+---@param pass string
+function mongo_db:auth(user, pass)
+
+end
+---执行命令
+function mongo_db:runCommand(cmd, cmd_v, ...)
+end
+---获取集合
+---@param collection string
+---@return mongo_collection
+function mongo_db:getCollection(collection)
+end
+---获取集合
+---@param collection string
+---@return mongo_collection
+function mongo_collection:getCollection(collection)
+end
+
+---向集合插入文档
+---@param doc table
+function mongo_collection:insert(doc)
+end
+---向集合安全的插入数据
+---@param dco table
+function mongo_collection:safe_insert(dco)
+end
+
+---插入批量数据
+---@param docs table[]
+function mongo_collection:batch_insert(docs)
+
+end
+---安全插入批量数据
+---@param docs table[]
+function mongo_collection:safe_batch_insert(docs)
+
+end
+---更新数据
+---@param selector table
+---@param update table
+---@param upsert boolean
+---@param multi boolean
+function mongo_collection:update(selector, update, upsert, multi)
+
+end
+---安全更新数据
+---@param selector table
+---@param update table
+---@param upsert boolean
+---@param multi boolean
+function mongo_collection:safe_update(selector, update, upsert, multi)
+
+end
+
+---删除数据
+---@param selector table
+---@param single boolean
+function mongo_collection:delete(selector, single)
+
+end
+---安全删除数据
+---@param selector table
+---@param single boolean
+function mongo_collection:safe_delete(selector, single)
+
+end
+---@param query table
+---@param selector table
+---@return mongo_cursor
+function mongo_collection:find(query, selector)
+
+end
+---@param query table
+---@param selector table
+---@return table
+function mongo_collection:findOne(query, selector)
+
+end
+
+---建立索引
+---* collection:createIndex { { key1 = 1}, { key2 = 1 }, unique = true }
+---* or collection:createIndex { "key1", "key2", unique = true }
+---* or collection:createIndex( { key1 = 1} , { unique = true } )	-- For compatibility
+---@param arg1 table
+---@param arg2 table
+function mongo_collection:createIndex(arg1, arg2)
+
+end
+---建立多个索引
+---@vararg table
+function mongo_collection:createIndexs(...)
+
+end
+mongo_collection.ensureIndex = mongo_collection.createIndex
+
+---删除集合
+function mongo_collection:drop()
+
+end
+--- 删除索引
+---* collection:dropIndex("age_1")
+---* collection:dropIndex("*")
+---@param indexName string 
+function mongo_collection:dropIndex(indexName)
+
+end
+
+---查找并修改
+---* collection:findAndModify({query = {name = "userid"}, update = {["$inc"] = {nextid = 1}}, })
+---* keys, value type
+---* query, table
+---* sort, table
+---* remove, bool
+---* update, table
+---* new, bool
+---* fields, bool
+---* upsert, boolean
+---@param doc table
+function mongo_collection:findAndModify(doc)
+
+end
+
+---排序
+---* cursor:sort { key = 1 } or cursor:sort( {key1 = 1}, {key2 = -1})
+---@param key table
+---@param key_v table
+function mongo_cursor:sort(key, key_v, ...)
+end
+---跳过多少行
+---@param amount number
+function mongo_cursor:skip(amount)
+end
+---限制行数
+---@param amount number
+function mongo_cursor:limit(amount)
+end
+---统计行数
+---@param with_limit_and_skip boolean
+function mongo_cursor:count(with_limit_and_skip)
+end
+---是否有下一行
+---@return boolean
+function mongo_cursor:hasNext()
+end
+---下一行
+---@return table
+function mongo_cursor:next()
+end
+---关闭游标
+function mongo_cursor:close()
+end
+return mongo

meta/3rd/skynet/library/skynet/db/mongo.lua

@@ -0,0 +1,17 @@
+---@meta
+---@class debug
+local debug = {}
+
+---初始化 debug 
+---@param skynet table
+---@param export table
+function debug.init(skynet, export)
+
+end
+---注册一个 debug 指令函数
+---@param name string
+---@param fn fun()
+function debug.reg_debugcmd(name, fn)
+
+end
+return debug

meta/3rd/skynet/library/skynet/debug.lua

@@ -0,0 +1,27 @@
+---@meta
+---* 多节点相关的 API
+---@class harbor
+local harbor = {}
+
+---* 注册一个全局名字。如果 handle 为空，则注册自己。skynet.name 和 skynet.register 是用其实现的。
+---@param name string @服务名称
+---@param handle number | nil @服务地址，可为空，表示注册自己
+function harbor.globalname(name, handle)
+end
+---* 可以用来查询全局名字或本地名字对应的服务地址。它是一个阻塞调用。
+---@param name string
+function harbor.queryname(name)
+end
+---* 用来监控一个 slave 是否断开。如果 harbor id 对应的 slave 正常，这个 api 将阻塞。当 slave 断开时，会立刻返回。
+---@param id number @harbor id
+function harbor.link(id)
+end
+---* 和 harbor.link 相反。如果 harbor id 对应的 slave 没有连接，这个 api 将阻塞，一直到它连上来才返回。
+---@param id number @harbor id
+function harbor.connect(id)
+end
+---* 用来在 slave 上监控和 master 的连接是否正常。这个 api 多用于异常时的安全退出（因为当 slave 和 master 断开后，没有手段可以恢复）。
+function harbor.linkmaster()
+end
+
+return harbor