namespace Memcached.ClientLibrary
{
    public partial class MemcachedClient
    {

        #region Methods
        public void DeleteByPattern(string pattern)
        {
            var regex = new Regex(pattern, RegexOptions.Singleline | RegexOptions.Compiled);
            var keysToRemove = new List<String>();

            foreach (var item in this.Keys)
                if (regex.IsMatch(item))
                    keysToRemove.Add(item);

            foreach (var key in keysToRemove)
                Delete(key);
        }
        #endregion

        #region Property
        /// <summary>
        /// 获取所有缓存的Key
        /// </summary>
        public List<String> Keys
        {
            get
            {
                List<String> keys = new List<string>();

                SockIOPool pool = SockIOPool.GetInstance(_poolName);
                if (pool != null && pool.Servers != null && pool.Servers.Count > 0)
                {
                    foreach (var server in pool.Servers)
                    {
                        var sock = pool.GetConnection((string)server);
                        if (sock == null) continue;

                        try
                        {
                            sock.Write(_commandStatsItems);
                            sock.Flush();
                            string line;
                            var items = new List<string>();
                            while (!END.Equals((line = sock.ReadLine()), StringComparison.Ordinal))
                            {
                                var id = line.Substring(_idIndex, line.LastIndexOf(':') - _idIndex);
                                if (!items.Contains(id))
                                    items.Add(id);
                            }

                            foreach (var id in items)
                            {
                                sock.Write(UTF8Encoding.UTF8.GetBytes(string.Concat("stats cachedump ", id, " 0\r\n")));
                                sock.Flush();

                                while (!END.Equals((line = sock.ReadLine()), StringComparison.Ordinal))
                                {
                                    var key = line.Substring(_keyIndex, line.LastIndexOf('[') - 6);
                                    keys.Add(key);
                                }
                            }
                        }
                        catch
                        {
                            try
                            {
                                sock.TrueClose();
                            }
                            catch(IOException)
                            {
                                if(log.IsErrorEnabled)
                                    log.Error(GetLocalizedString("failed to close some socket").Replace("$$Socket$$", sock.ToString()));  
                            }
                        }
                        finally
                        {
                            if (sock != null)
                                sock.Close();
                        }

                    }


                }

                return keys;
            }
        }
        #endregion

        #region Fields
        private const int _idIndex = 11;
        private const int _keyIndex = 5;
        private readonly byte[] _commandStatsItems = UTF8Encoding.UTF8.GetBytes("stats items\r\n");
        #endregion
    }
}