astrobase/cpserver/checkplotserver_handlers.py
def post(self, cpfile):
        '''This handles POST requests.

        Also an AJAX endpoint. Updates the persistent checkplot dict using the
        changes from the UI, and then saves it back to disk. This could
        definitely be faster by just loading the checkplot into a server-wide
        shared dict or something.

        '''

        # if self.readonly is set, then don't accept any changes
        # return immediately with a 400
        if self.readonly:

            msg = "checkplotserver is in readonly mode. no updates allowed."
            resultdict = {'status':'error',
                          'message':msg,
                          'readonly':self.readonly,
                          'result':None}

            self.write(resultdict)
            raise tornado.web.Finish()

        # now try to update the contents
        try:

            self.cpfile = base64.b64decode(url_unescape(cpfile)).decode()
            cpcontents = self.get_argument('cpcontents', default=None)
            savetopng = self.get_argument('savetopng', default=None)

            if not self.cpfile or not cpcontents:

                msg = "did not receive a checkplot update payload"
                resultdict = {'status':'error',
                              'message':msg,
                              'readonly':self.readonly,
                              'result':None}

                self.write(resultdict)
                raise tornado.web.Finish()

            cpcontents = json.loads(cpcontents)

            # the only keys in cpdict that can updated from the UI are from
            # varinfo, objectinfo (objecttags), uifilters, and comments
            updated = {'varinfo': cpcontents['varinfo'],
                       'objectinfo':cpcontents['objectinfo'],
                       'comments':cpcontents['comments'],
                       'uifilters':cpcontents['uifilters']}

            # we need to reform the self.cpfile so it points to the full path
            cpfpath = os.path.join(
                os.path.abspath(os.path.dirname(self.cplistfile)),
                self.cpfile
            )

            LOGGER.info('loading %s...' % cpfpath)

            if not os.path.exists(cpfpath):

                msg = "couldn't find checkplot %s" % cpfpath
                LOGGER.error(msg)
                resultdict = {'status':'error',
                              'message':msg,
                              'readonly':self.readonly,
                              'result':None}

                self.write(resultdict)
                raise tornado.web.Finish()

            # dispatch the task
            updated = yield self.executor.submit(checkplot_pickle_update,
                                                 cpfpath, updated)

            # continue processing after this is done
            if updated:

                LOGGER.info('updated checkplot %s successfully' % updated)

                resultdict = {'status':'success',
                              'message':'checkplot update successful',
                              'readonly':self.readonly,
                              'result':{'checkplot':updated,
                                        'unixtime':utime.time(),
                                        'changes':cpcontents,
                                        'cpfpng': None}}

                # handle a savetopng trigger
                if savetopng:

                    cpfpng = os.path.abspath(cpfpath.replace('.pkl','.png'))
                    cpfpng = StrIO()
                    pngdone = yield self.executor.submit(
                        checkplot_pickle_to_png,
                        cpfpath, cpfpng
                    )

                    if pngdone is not None:

                        # we'll send back the PNG, which can then be loaded by
                        # the frontend and reformed into a download
                        pngdone.seek(0)
                        pngbin = pngdone.read()
                        pngb64 = base64.b64encode(pngbin)
                        pngdone.close()
                        del pngbin
                        resultdict['result']['cpfpng'] = pngb64

                    else:
                        resultdict['result']['cpfpng'] = ''


                self.write(resultdict)
                self.finish()

            else:
                LOGGER.error('could not handle checkplot update for %s: %s' %
                             (self.cpfile, cpcontents))
                msg = "checkplot update failed because of a backend error"
                resultdict = {'status':'error',
                              'message':msg,
                              'readonly':self.readonly,
                              'result':None}
                self.write(resultdict)
                self.finish()

        # if something goes wrong, inform the user
        except Exception as e:

            LOGGER.exception('could not handle checkplot update for %s: %s' %
                             (self.cpfile, cpcontents))
            msg = "checkplot update failed because of an exception"
            resultdict = {'status':'error',
                          'message':msg,
                          'readonly':self.readonly,
                          'result':None}
            self.write(resultdict)
            self.finish()
def post(self, cpfile):
        '''This handles POST requests.

        Also an AJAX endpoint. Updates the persistent checkplot dict using the
        changes from the UI, and then saves it back to disk. This could
        definitely be faster by just loading the checkplot into a server-wide
        shared dict or something.

        '''

        # if self.readonly is set, then don't accept any changes
        # return immediately with a 400
        if self.readonly:

            msg = "checkplotserver is in readonly mode. no updates allowed."
            resultdict = {'status':'error',
                          'message':msg,
                          'readonly':self.readonly,
                          'result':None}

            self.write(resultdict)
            raise tornado.web.Finish()

        # now try to update the contents
        try:

            self.cpfile = base64.b64decode(url_unescape(cpfile)).decode()
            cpcontents = self.get_argument('cpcontents', default=None)
            savetopng = self.get_argument('savetopng', default=None)

            if not self.cpfile or not cpcontents:

                msg = "did not receive a checkplot update payload"
                resultdict = {'status':'error',
                              'message':msg,
                              'readonly':self.readonly,
                              'result':None}

                self.write(resultdict)
                raise tornado.web.Finish()

            cpcontents = json.loads(cpcontents)

            # the only keys in cpdict that can updated from the UI are from
            # varinfo, objectinfo (objecttags), uifilters, and comments
            updated = {'varinfo': cpcontents['varinfo'],
                       'objectinfo':cpcontents['objectinfo'],
                       'comments':cpcontents['comments'],
                       'uifilters':cpcontents['uifilters']}

            # we need to reform the self.cpfile so it points to the full path
            cpfpath = os.path.join(
                os.path.abspath(os.path.dirname(self.cplistfile)),
                self.cpfile
            )

            LOGGER.info('loading %s...' % cpfpath)

            if not os.path.exists(cpfpath):

                msg = "couldn't find checkplot %s" % cpfpath
                LOGGER.error(msg)
                resultdict = {'status':'error',
                              'message':msg,
                              'readonly':self.readonly,
                              'result':None}

                self.write(resultdict)
                raise tornado.web.Finish()

            # dispatch the task
            updated = yield self.executor.submit(checkplot_pickle_update,
                                                 cpfpath, updated)

            # continue processing after this is done
            if updated:

                LOGGER.info('updated checkplot %s successfully' % updated)

                resultdict = {'status':'success',
                              'message':'checkplot update successful',
                              'readonly':self.readonly,
                              'result':{'checkplot':updated,
                                        'unixtime':utime.time(),
                                        'changes':cpcontents,
                                        'cpfpng': None}}

                # handle a savetopng trigger
                if savetopng:

                    cpfpng = os.path.abspath(cpfpath.replace('.pkl','.png'))
                    cpfpng = StrIO()
                    pngdone = yield self.executor.submit(
                        checkplot_pickle_to_png,
                        cpfpath, cpfpng
                    )

                    if pngdone is not None:

                        # we'll send back the PNG, which can then be loaded by
                        # the frontend and reformed into a download
                        pngdone.seek(0)
                        pngbin = pngdone.read()
                        pngb64 = base64.b64encode(pngbin)
                        pngdone.close()
                        del pngbin
                        resultdict['result']['cpfpng'] = pngb64

                    else:
                        resultdict['result']['cpfpng'] = ''


                self.write(resultdict)
                self.finish()

            else:
                LOGGER.error('could not handle checkplot update for %s: %s' %
                             (self.cpfile, cpcontents))
                msg = "checkplot update failed because of a backend error"
                resultdict = {'status':'error',
                              'message':msg,
                              'readonly':self.readonly,
                              'result':None}
                self.write(resultdict)
                self.finish()

        # if something goes wrong, inform the user
        except Exception as e:

            LOGGER.exception('could not handle checkplot update for %s: %s' %
                             (self.cpfile, cpcontents))
            msg = "checkplot update failed because of an exception"
            resultdict = {'status':'error',
                          'message':msg,
                          'readonly':self.readonly,
                          'result':None}
            self.write(resultdict)
            self.finish()
def post ( self , cpfile ) : # if self.readonly is set, then don't accept any changes # return immediately with a 400 if self . readonly : msg = "checkplotserver is in readonly mode. no updates allowed." resultdict = { 'status' : 'error' , 'message' : msg , 'readonly' : self . readonly , 'result' : None } self . write ( resultdict ) raise tornado . web . Finish ( ) # now try to update the contents try : self . cpfile = base64 . b64decode ( url_unescape ( cpfile ) ) . decode ( ) cpcontents = self . get_argument ( 'cpcontents' , default = None ) savetopng = self . get_argument ( 'savetopng' , default = None ) if not self . cpfile or not cpcontents : msg = "did not receive a checkplot update payload" resultdict = { 'status' : 'error' , 'message' : msg , 'readonly' : self . readonly , 'result' : None } self . write ( resultdict ) raise tornado . web . Finish ( ) cpcontents = json . loads ( cpcontents ) # the only keys in cpdict that can updated from the UI are from # varinfo, objectinfo (objecttags), uifilters, and comments updated = { 'varinfo' : cpcontents [ 'varinfo' ] , 'objectinfo' : cpcontents [ 'objectinfo' ] , 'comments' : cpcontents [ 'comments' ] , 'uifilters' : cpcontents [ 'uifilters' ] } # we need to reform the self.cpfile so it points to the full path cpfpath = os . path . join ( os . path . abspath ( os . path . dirname ( self . cplistfile ) ) , self . cpfile ) LOGGER . info ( 'loading %s...' % cpfpath ) if not os . path . exists ( cpfpath ) : msg = "couldn't find checkplot %s" % cpfpath LOGGER . error ( msg ) resultdict = { 'status' : 'error' , 'message' : msg , 'readonly' : self . readonly , 'result' : None } self . write ( resultdict ) raise tornado . web . Finish ( ) # dispatch the task updated = yield self . executor . submit ( checkplot_pickle_update , cpfpath , updated ) # continue processing after this is done if updated : LOGGER . info ( 'updated checkplot %s successfully' % updated ) resultdict = { 'status' : 'success' , 'message' : 'checkplot update successful' , 'readonly' : self . readonly , 'result' : { 'checkplot' : updated , 'unixtime' : utime . time ( ) , 'changes' : cpcontents , 'cpfpng' : None } } # handle a savetopng trigger if savetopng : cpfpng = os . path . abspath ( cpfpath . replace ( '.pkl' , '.png' ) ) cpfpng = StrIO ( ) pngdone = yield self . executor . submit ( checkplot_pickle_to_png , cpfpath , cpfpng ) if pngdone is not None : # we'll send back the PNG, which can then be loaded by # the frontend and reformed into a download pngdone . seek ( 0 ) pngbin = pngdone . read ( ) pngb64 = base64 . b64encode ( pngbin ) pngdone . close ( ) del pngbin resultdict [ 'result' ] [ 'cpfpng' ] = pngb64 else : resultdict [ 'result' ] [ 'cpfpng' ] = '' self . write ( resultdict ) self . finish ( ) else : LOGGER . error ( 'could not handle checkplot update for %s: %s' % ( self . cpfile , cpcontents ) ) msg = "checkplot update failed because of a backend error" resultdict = { 'status' : 'error' , 'message' : msg , 'readonly' : self . readonly , 'result' : None } self . write ( resultdict ) self . finish ( ) # if something goes wrong, inform the user except Exception as e : LOGGER . exception ( 'could not handle checkplot update for %s: %s' % ( self . cpfile , cpcontents ) ) msg = "checkplot update failed because of an exception" resultdict = { 'status' : 'error' , 'message' : msg , 'readonly' : self . readonly , 'result' : None } self . write ( resultdict ) self . finish ( )
This handles POST requests.

        Also an AJAX endpoint. Updates the persistent checkplot dict using the
        changes from the UI, and then saves it back to disk. This could
        definitely be faster by just loading the checkplot into a server-wide
        shared dict or something.
This handles POST requests .