#!/usr/bin/env python -i 
# Provide a function to return the SNs index for a SQL query.
#
import numpy as np
import sqlite3 as sq3
import msgpack as msg
import msgpack_numpy as mn

mn.patch()

class supernova(object):
     """Attributes can be added"""

def selectsn(sndb,sqlstr):

     con = sq3.connect(sndb)
     cur = con.cursor()
     
     cur.execute(sqlstr)

     SN_Array = []
     names = []
     for row in cur:
          SN = supernova()
          SN.filename = row[0]
          SN.name = row[1]
          SN.redshift = row[2]
          SN.minwave = row[3]
#           spectra = msg.unpackb(row[5])
#           SN.spectrum = spectra
          SN_Array.append(SN)

#!/usr/bin/env python
# -*- coding: utf-8 -*-
# File: serialize.py
# Author: Yuxin Wu <[email protected]>

import msgpack
import msgpack_numpy
msgpack_numpy.patch()

__all__ = ['loads', 'dumps']


def dumps(obj):
    """
    Serialize an object.

    Returns:
        str
    """
    return msgpack.dumps(obj, use_bin_type=True)


def loads(buf):
    """
    Args:
        buf (str): serialized object.
    """
    return msgpack.loads(buf)

import sys
from datetime import datetime
from datetime import date   
import pdb
import colorama
colorama.init(strip=False)

import msgpack
import msgpack_numpy


import simplejson
import XTSMobjectify
import DataBomb
import InfiniteFileStream
msgpack_numpy.patch()#This patch actually changes the behavior of "msgpack"
#specifically, it changes how, "encoding='utf-8'" functions when unpacking
import XTSM_Server_Objects
import file_locations


import numpy
from enthought.traits.api import HasTraits
from enthought.traits.api import Int as TraitedInt
from enthought.traits.api import Str as TraitedStr

import collections
DEBUG = True
      
NUM_RETAINED_XTSM=10

Copyright (C) 2012-2013 iSolver Software Solutions
Distributed under the terms of the GNU General Public License (GPL version 3 or any later version).

.. moduleauthor:: Sol Simpson <[email protected]> + contributors, please see credits section of documentation.
.. fileauthor:: Sol Simpson <[email protected]>
"""
from __future__ import division

from builtins import range
from builtins import object
from psychopy.iohub import Computer
import msgpack
try:
    import msgpack_numpy as m
    m.patch()
except Exception:
    pass
import struct
from weakref import proxy
from psychopy.iohub.util import NumPyRingBuffer as RingBuffer
from psychopy.iohub import print2err, printExceptionDetailsToStdErr
getTime=Computer.getTime

MAX_PACKET_SIZE=64*1024

from gevent import sleep, Greenlet

class SocketConnection(object):
    def __init__(self,local_host=None,local_port=None,remote_host=None,remote_port=None,rcvBufferLength=1492, broadcast=False, blocking=0, timeout=0):
        self._local_port= local_port

 def setUp(self):
      patch()