shikyoh / car8 Goto Github PK

  public class UnSortedSet<T>
    {
        internal UnSortedSet(RedisDB db, string key, IDataFormater dataFormater = null)
        {
            DB = db;
            Key = key;
            DataFormater = dataFormater;
        }

        public string Key { get; private set; }

        internal RedisDB DB { get; set; }

        public IDataFormater DataFormater { get; set; }

        public async ValueTask<long> Card()
        {
            SCARD cmd = new SCARD(Key);
            var result = await DB.Execute(cmd, typeof(string));
            if (result.IsError)
                throw new RedisException(result.Messge);
            return System.Convert.ToInt64(result.Value);
        }

        public async ValueTask<long> Add(params T[] values)
        {
            SADD cmd = new SADD(Key, DataFormater);
            for (int i = 0; i < values.Length; i++)
                cmd.Values.Add(values[i]);
            var result = await DB.Execute(cmd, typeof(T));
            if (result.IsError)
                throw new RedisException(result.Messge);
            return (long)result.Value;
        }

        public async ValueTask<T[]> Members()
        {
            SMEMBERS cmd = new SMEMBERS(Key, DataFormater);
            var result = await DB.Execute(cmd, typeof(T));
            if (result.IsError)
                throw new RedisException(result.Messge);
            return (from a in result.Data select (T)a.Data).ToArray();
        }

        public async ValueTask<long> Rem(params T[] members)
        {
            if (members == null || members.Length == 0)
                return 0;
            SREM cmd = new SREM(Key, DataFormater);
            for (int i = 0; i < members.Length; i++)
                cmd.Values.Add(members[i]);
            var result = await DB.Execute(cmd, typeof(T));
            if (result.IsError)
                throw new RedisException(result.Messge);
            return (long)result.Value;
        }

        public async ValueTask<bool> IsMember(T member)
        {
            SISMEMBER cmd = new SISMEMBER(Key, member, DataFormater);
            var result = await DB.Execute(cmd, typeof(T));
            if (result.IsError)
                throw new RedisException(result.Messge);
            return (long)result.Value > 0;
        }
    }