Coverage for marshall_webapp/models/transients/element/models_transients_element

Hot-keys on this page

r m x p toggle line displays

j k next/prev highlighted chunk

0 (zero) top of page

1 (one) first highlighted chunk

1#!/usr/local/bin/python

2# encoding: utf-8

3"""

4*The HTML template module for the `models_transients_element_put.py` resource*

6:Author:

7 David Young

8"""

9from builtins import zip

10from builtins import object

11import sys

12import os

13import khufu

14from datetime import datetime, date, time

17class models_transients_element_put(object):

18 """

19 The worker class for the models_transients_element_put module

21 **Key Arguments**

23 - ``log`` -- logger

24 - ``request`` -- the pyramid request

25 """

27 def __init__(

28 self,

29 log,

30 request

31 ):

32 self.log = log

33 self.request = request

34 self.transientBucketId = request.matchdict["elementId"]

35 self.response = ""

36 # xt-self-arg-tmpx

38 log.debug("instansiating a new 'models_transients_element_put' object")

40 return None

42 def close(self):

43 del self

44 return None

46 def put(self):

47 """get the models_transients_element_put object

49 **Return**

51 - ``response``

52 """

53 self.log.debug('starting the ``get`` method')

55 # move the objects to another list if requested

56 if "mwl" in self.request.params or "awl" in self.request.params:

57 self._move_transient_to_another_list()

59 # change the pi is requested

60 if set(("piName", "piEmail")) <= set(self.request.params):

61 self._change_pi_for_object()

63 if "observationPriority" in self.request.params:

64 self._set_observational_priority_for_object()

66 # throw warning if nothing has changed

67 if len(self.response) == 0:

68 self.response = "nothing has changed"

70 self.log.debug('completed the ``get`` method')

72 return self.response

74 def _move_transient_to_another_list(

75 self):

76 """ create sqlquery for the put request

77 """

78 self.log.debug('starting the ``_create_sqlquery`` method')

79 transientBucketId = self.transientBucketId

81 sqlQuery = u"""

82 select marshallWorkflowLocation, alertWorkflowLocation from pesstoObjects where transientBucketId = %(transientBucketId)s

83 """ % locals()

84 objectDataTmp = self.request.db.execute(sqlQuery).fetchall()

85 objectData = []

86 objectData[:] = [dict(list(zip(list(row.keys()), row)))

87 for row in objectDataTmp]

89 oldMwl = objectData[0]["marshallWorkflowLocation"]

90 oldAwl = objectData[0]["alertWorkflowLocation"]

91 username = self.request.authenticated_userid.replace(".", " ").title()

92 now = datetime.now()

93 now = now.strftime("%Y-%m-%d %H:%M:%S")

95 # CHANGE THE MARSHALL WORKFLOW LOCATION LIST IF REQUESTED

96 if "mwl" in self.request.params:

97 mwl = self.request.params["mwl"]

98 if "snoozed" in self.request.params:

99 logEntry = "object snoozed by %(username)s" % locals(

100 )

101 snoozed = ", snoozed = 1"

102 else:

103 logEntry = "moved from '%(oldMwl)s' to '%(mwl)s' list by %(username)s" % locals(

104 )

105 snoozed = ", snoozed = 0"

106

107 sqlQuery = """

108 update pesstoObjects set marshallWorkflowLocation = "%(mwl)s" %(snoozed)s where transientBucketId = %(transientBucketId)s

109 """ % locals()

110 self.request.db.execute(sqlQuery)

111 self.request.db.commit()

112 self.response = self.response + \

113 " transientBucketId %(transientBucketId)s moved to the `%(mwl)s` marshallWorkflowLocation<BR>" % locals(

114 )

115

116 for o, n in zip(["pending observation", "following", "pending classification"], ["classification targets", "followup targets", "queued for classification"]):

117 logEntry = logEntry.replace(o, n)

118

119 sqlQuery = u"""insert ignore into transients_history_logs (

120 transientBucketId,

121 dateCreated,

122 log

123 )

124 VALUES (

125 %s,

126 "%s",

127 "%s"

128 )""" % (transientBucketId, now, logEntry)

129 self.request.db.execute(sqlQuery)

130 self.request.db.commit()

131

132 # RESET PRIORITY IF REQUIRED

133 if mwl == "following":

134 sqlQuery = """

135 update pesstoObjects set observationPriority = 2 where transientBucketId = %(transientBucketId)s

136 """ % locals()

137 self.request.db.execute(sqlQuery)

138 self.request.db.commit()

139

140 # RESET THE LAST TIME REVIEWE IF REQUIRED

141 if mwl == "archive":

142 now = datetime.now()

143 now = now.strftime("%Y-%m-%d %H:%M:%S")

144 sqlQuery = """

145 update pesstoObjects set lastReviewedMagDate = "%(now)s" where transientBucketId = %(transientBucketId)s

146 """ % locals()

147 self.request.db.execute(sqlQuery)

148 self.request.db.commit()

149

150 # CHANGE THE ALERT WORKFLOW LOCATION LIST IF REQUESTED

151 if "awl" in self.request.params:

152 awl = self.request.params["awl"]

153 sqlQuery = """

154 update pesstoObjects set alertWorkflowLocation = "%(awl)s", snoozed = 0 where transientBucketId = %(transientBucketId)s

155 """ % locals()

156 self.request.db.execute(sqlQuery)

157 self.request.db.commit()

158 self.response = self.response + \

159 " transientBucketId %(transientBucketId)s moved to the `%(awl)s` alertWorkflowLocation<BR>" % locals(

160 )

161

162 logEntry = "moved from '%(oldAwl)s' to '%(awl)s' list by %(username)s" % locals(

163 )

164 for o, n in zip(["pending observation", "following", "pending classification"], ["classification targets", "followup targets", "queued for classification"]):