1import logging 

2 

3from pyrocko import gf, util 

4from pyrocko.guts import String, Float, Dict, Int 

5 

6from grond.meta import expand_template, Parameter, \ 

7 has_get_plot_classes 

8 

9from ..base import Problem, ProblemConfig 

10 

11guts_prefix = 'grond' 

12logger = logging.getLogger('grond.problems.volume_point') 

13km = 1e3 

14as_km = dict(scale_factor=km, scale_unit='km') 

15as_km3 = dict(scale_factor=km**3, scale_unit='km^3') 

16 

17 

18class VLVDProblemConfig(ProblemConfig): 

19 ranges = Dict.T(String.T(), gf.Range.T()) 

20 distance_min = Float.T(default=0.0) 

21 nthreads = Int.T(default=1) 

22 

23 def get_problem(self, event, target_groups, targets): 

24 if event.depth is None: 

25 event.depth = 0. 

26 

27 base_source = gf.VLVDSource.from_pyrocko_event(event) 

28 base_source.stf = gf.HalfSinusoidSTF(duration=event.duration or 0.0) 

29 

30 subs = dict( 

31 event_name=event.name, 

32 event_time=util.time_to_str(event.time)) 

33 

34 problem = VLVDProblem( 

35 name=expand_template(self.name_template, subs), 

36 base_source=base_source, 

37 target_groups=target_groups, 

38 targets=targets, 

39 ranges=self.ranges, 

40 distance_min=self.distance_min, 

41 norm_exponent=self.norm_exponent, 

42 nthreads=self.nthreads) 

43 

44 return problem 

45 

46 

47@has_get_plot_classes 

48class VLVDProblem(Problem): 

49 

50 problem_parameters = [ 

51 Parameter('north_shift', 'm', label='Northing', **as_km), 

52 Parameter('east_shift', 'm', label='Easting', **as_km), 

53 Parameter('depth', 'm', label='Depth', **as_km), 

54 

55 Parameter('dip', 'deg', label='Dip'), 

56 Parameter('azimuth', 'deg', label='Azimuth'), 

57 Parameter('clvd_moment', 'Nm', label='CLVD Moment'), 

58 Parameter('volume_change', 'm^3', label='Volume Change', **as_km3), 

59 

60 ] 

61 

62 problem_waveform_parameters = [ 

63 Parameter('time', 's', label='Time'), 

64 Parameter('duration', 's', label='Duration') 

65 ] 

66 

67 distance_min = Float.T(default=0.0) 

68 

69 def pack(self, source): 

70 arr = self.get_parameter_array(source) 

71 for ip, p in enumerate(self.parameters): 

72 if p.name == 'time': 

73 arr[ip] -= self.base_source.time 

74 return arr 

75 

76 def get_source(self, x): 

77 d = self.get_parameter_dict(x) 

78 

79 p = {k: float(self.ranges[k].make_relative(self.base_source[k], d[k])) 

80 for k in self.base_source.keys() if k in d} 

81 

82 stf = None 

83 if self.has_waveforms: 

84 stf = gf.HalfSinusoidSTF(duration=float(d.duration)) 

85 

86 source = self.base_source.clone(stf=stf, **p) 

87 return source 

88 

89 @classmethod 

90 def get_plot_classes(cls): 

91 from . import plot 

92 plots = super(VLVDProblem, cls).get_plot_classes() 

93 plots.extend([plot.VLVDLocationPlot]) 

94 return plots