#!/usr/bin/env python3
import math
import sys
import os
import time
import pybullet as p
from time import sleep
import time

import rospy
import tf
from scipy import signal
import pybullet_data
import rospkg
from transforms3d.quaternions import quat2mat

from wolfgang_pybullet_sim.terrain import Terrain
import numpy as np


class Simulation:
    def __init__(self, gui, urdf_path=None, foot_link_names=[], terrain=False, field=True, joints_ft=False,
                 robot="wolfgang"):
        self.gui = gui
        self.paused = False
        self.gravity = True
        self.terrain_on = terrain
        self.field_on = field
        self.urdf_path = urdf_path
        self.foot_link_names = foot_link_names
        self.joints_ft = joints_ft
        self.robot = robot

        # config values
        self.start_position = [0, 0, 0.43]
        self.start_orientation = p.getQuaternionFromEuler((0, 0.25, 0))
        if self.robot == "wolfgang":
            self.initial_joints_positions = {"LAnklePitch": -30, "LAnkleRoll": 0, "LHipPitch": 30, "LHipRoll": 0,
                                             "LHipYaw": 0, "LKnee": 60, "RAnklePitch": 30, "RAnkleRoll": 0,
                                             "RHipPitch": -30, "RHipRoll": 0, "RHipYaw": 0, "RKnee": -60,
                                             "LShoulderPitch": 0, "LShoulderRoll": 0, "LElbow": 45, "RShoulderPitch": 0,
                                             "RShoulderRoll": 0, "RElbow": -45, "HeadPan": 0, "HeadTilt": 0}
        elif self.robot in ["op2", "robotis_op2"]:
            self.initial_joints_positions = {"l_ankle_pitch": 0, "l_ankle_roll": 0, "l_hip_pitch": 0, "l_hip_roll": 0,
                                             "l_hip_yaw": 0, "l_knee": 0, "r_ankle_pitch": 0, "r_ankle_roll": 0,
                                             "r_hip_pitch": 0, "r_hip_roll": 0, "r_hip_yaw": 0, "r_knee": 0,
                                             "l_sho_pitch": 0, "l_sho_roll": 0, "LElbow": 0, "r_sho_pitch": 0,
                                             "r_sho_roll": 0, "RElbow": 0, "head_pan": 0, "head_tilt": 0}
            self.foot_link_names = ["l_foot", "r_foot"]
        elif self.robot == "sigmaban":
            self.start_orientation = p.getQuaternionFromEuler((0, 0.0, 0))
            self.initial_joints_positions = {"left_ankle_pitch": 0, "left_ankle_roll": 0, "left_hip_pitch": 0,
                                             "left_hip_roll": 0, "left_hip_yaw": 0, "left_knee": 0,
                                             "right_ankle_pitch": 0, "right_ankle_roll": 0, "right_hip_pitch": 0,
                                             "right_hip_roll": 0, "right_hip_yaw": 0, "right_knee": 0,
                                             "left_shoulder_pitch": 0, "left_shoulder_roll": 0, "LElbow": 0,
                                             "right_shoulder_pitch": 0, "right_shoulder_roll": 0, "RElbow": 0,
                                             "head_yaw": 0, "head_pitch": 0}
        else:
            print(f"robot {self.robot} not known")
            quit(0)
        # Instantiating Bullet
        if self.gui:
            self.client_id = p.connect(p.GUI)
        else:
            self.client_id = p.connect(p.DIRECT)
        if self.gravity:
            p.setGravity(0, 0, -9.81)
        self.time = 0
        # disable debug interface, only show robot
        p.configureDebugVisualizer(p.COV_ENABLE_GUI, False)

        # Engine parameters
        # time step should be at 240Hz (due to pyBullet documentation)
        self.timestep = 1 / 240
        # standard parameters seem to be best. leave them like they are
        # p.setPhysicsEngineParameter(fixedTimeStep=self.timestep, numSubSteps=1)
        # no real time, as we will publish own clock, but we have option to switch to real_time by waiting
        self.real_time = False
        p.setRealTimeSimulation(0)
        self.last_wall_time = time.time()

        self.load_models()

    def load_models(self):
        print("load models")
        # Load floor
        self.terrain_index = None
        self.plane_index = None
        if self.terrain_on:
            self.max_terrain_height = 0.01
            self.terrain = Terrain(self.max_terrain_height)
            self.terrain_index = self.terrain.id
        else:
            p.setAdditionalSearchPath(pybullet_data.getDataPath())  # needed for plane.urdf
            self.plane_index = p.loadURDF('plane.urdf')

        self.field_index = None
        if self.field_on:
            # Load field
            rospack = rospkg.RosPack()
            path = os.path.join(rospack.get_path('wolfgang_pybullet_sim'), 'models')
            p.setAdditionalSearchPath(path)  # needed to find field model
            self.field_index = p.loadURDF('field/field.urdf')

        # Load robot, deactivate all self collisions
        if self.robot in ["wolfgang", "sigmaban"]:
            # we have a better inertia estimation from onshape in our model
            flags = p.URDF_USE_SELF_COLLISION + p.URDF_USE_INERTIA_FROM_FILE
        else:
            # most other URDFs from the internet have issues with their inertia values
            flags = p.URDF_USE_SELF_COLLISION

        if self.urdf_path is None:
            # use wolfgang as standard
            rospack = rospkg.RosPack()
            if self.robot == "op2":
                self.urdf_path = rospack.get_path("robotis_op2_description") + "/urdf/robot.urdf"
            elif self.robot == "sigmaban":
                self.urdf_path = rospack.get_path("sigmaban_description") + "/urdf/robot.urdf"
            else:
                self.urdf_path = rospack.get_path("wolfgang_description") + "/urdf/robot.urdf"
        self.robot_index = p.loadURDF(self.urdf_path, self.start_position, self.start_orientation, flags=flags)

        # Retrieving joints and foot pressure sensors
        self.joints = {}
        self.pressure_sensors = {}
        self.links = {}

        # Collecting the available joints
        link_index = 0
        for i in range(p.getNumJoints(self.robot_index)):
            joint_info = p.getJointInfo(self.robot_index, i)
            name = joint_info[1].decode('utf-8')
            type = joint_info[2]
            # we can get the links by seeing where the joint is attached
            self.links[joint_info[12].decode('utf-8')] = link_index
            link_index += 1
            # see if it is a joint
            if type == 0:
                if self.joints_ft:
                    p.enableJointForceTorqueSensor(self.robot_index, i)
                # remember joint if its revolute (0) and not fixed (4)
                self.joints[name] = Joint(i, self.robot_index, ft=self.joints_ft)
            elif name in ["LLB", "LLF", "LRF", "LRB", "RLB", "RLF", "RRF", "RRB"]:
                p.enableJointForceTorqueSensor(self.robot_index, i)
                self.pressure_sensors[name] = PressureSensor(name, i, self.robot_index, 10, 5)

        for linkA in self.links.keys():
            for linkB in self.links.keys():
                p.setCollisionFilterPair(self.robot_index, self.robot_index, self.links[linkA],
                                         self.links[linkB], 0)
        hip_group = []
        foot_group = []
        if self.robot in ("wolfgang", "op2", "robotis_op2"):
            # set collisions for hip and ankle towards each other, otherwise stand up is not realistic
            hip_group = ["torso", "r_hip_1", "r_hip_2", "l_hip_1", "l_hip_2"]
            foot_group = ["r_ankle", "r_foot", "l_ankle", "l_foot"]
        elif self.robot in ("sigmaban"):
            hip_group = ["mx106_block_mir_1", "u_block_1", "right_knee_1", "left_knee_1", "mx106_block_2", "u_block_2"]
            foot_group = ["tibia_1", "mx106_block_1", "right_foot_cleat_back_left", "mx106_block_mir_2",
                          "left_foot_cleat_front_right", "tibia_2"]
        for hip_link_index in hip_group:
            for foot_link_index in foot_group:
                p.setCollisionFilterPair(self.robot_index, self.robot_index, self.links[hip_link_index],
                                         self.links[foot_link_index], 1)
        # reset robot to initial position
        self.reset()

    def apply_force(self, link_id, force, position):
        """
        Applies an external force to a position on a link.
        :param link_id: link index or -1 for base link (int)
        :param force: direction and amount of applied force (vec3)
        :param position: where on the link the force should be applied (vec3)
        """
        p.applyExternalForce(self.robot_index, link_id, force, position, flags=p.WORLD_FRAME)

    def set_foot_dynamics(self, contact_damping, contact_stiffness, joint_damping, lateral_friction=1,
                          spinning_friction=1, rolling_friction=1, restitution=0):
        # set dynamic values for all links and ground
        for link_name in self.links.keys():
            if link_name in ["llb", "llf", "lrf", "lrb", "rlb", "rlf", "rrf",
                             "rrb"] or link_name in self.foot_link_names:
                # print(p.getLinkState(self.robot_index, self.links[link_name]))
                p.changeDynamics(self.robot_index, self.links[link_name],
                                 lateralFriction=lateral_friction,
                                 spinningFriction=spinning_friction,
                                 rollingFriction=rolling_friction,
                                 contactDamping=contact_damping,
                                 contactStiffness=contact_stiffness,
                                 jointDamping=joint_damping,
                                 restitution=restitution)
        if self.plane_index:
            p.changeDynamics(self.plane_index, -1, lateralFriction=lateral_friction, spinningFriction=spinning_friction,
                             rollingFriction=rolling_friction, restitution=restitution, contactDamping=contact_damping,
                             contactStiffness=contact_stiffness, jointDamping=joint_damping)
        if self.field_index:
            p.changeDynamics(self.field_index, -1, lateralFriction=lateral_friction, spinningFriction=spinning_friction,
                             rollingFriction=rolling_friction, restitution=restitution, contactDamping=contact_damping,
                             contactStiffness=contact_stiffness, jointDamping=joint_damping)
        if self.terrain_index:
            p.changeDynamics(self.terrain_index, -1, lateralFriction=lateral_friction,
                             spinningFriction=spinning_friction,
                             rollingFriction=rolling_friction, restitution=restitution, contactDamping=contact_damping,
                             contactStiffness=contact_stiffness, jointDamping=joint_damping)

    def set_filter_params(self, cutoff, order):
        for i in range(p.getNumJoints(self.robot_index)):
            joint_info = p.getJointInfo(self.robot_index, i)
            name = joint_info[1].decode('utf-8')
            if name in ["LLB", "LLF", "LRF", "LRB", "RLB", "RLF", "RRF", "RRB"]:
                self.pressure_sensors[name] = PressureSensor(name, i, self.robot_index, cutoff, order)

    def reset(self):
        # set joints to initial position
        for name in self.joints:
            joint = self.joints[name]
            try:
                pos_in_rad = math.radians(self.initial_joints_positions[name])
            except KeyError:
                pos_in_rad = 0
            joint.reset_position(pos_in_rad, 0)
            joint.set_position(pos_in_rad)

        # reset body pose and velocity
        p.resetBasePositionAndOrientation(self.robot_index, self.start_position, self.start_orientation)
        p.resetBaseVelocity(self.robot_index, [0, 0, 0], [0, 0, 0])

    def step(self):
        # get keyboard events if gui is active
        if self.gui:
            # reset if R-key was pressed
            rKey = ord('r')
            # gravity
            nKey = ord('n')
            # single step
            xKey = ord('x')
            # real time
            tKey = ord('t')
            # randomize terrain
            fKey = ord('f')
            # pause
            spaceKey = p.B3G_SPACE
            # rotate robot for testing
            jKey = ord('j')
            kKey = ord('k')
            lKey = ord('l')
            # move robot for testing
            qKey = ord('q')
            aKey = ord('a')
            sKey = ord('s')
            dKey = ord('d')
            keys = p.getKeyboardEvents()
            if rKey in keys and keys[rKey] & p.KEY_WAS_TRIGGERED:
                self.reset()
            if spaceKey in keys and keys[spaceKey] & p.KEY_WAS_TRIGGERED:
                self.paused = not self.paused
            if nKey in keys and keys[nKey] & p.KEY_WAS_TRIGGERED:
                self.set_gravity(not self.gravity)
            if tKey in keys and keys[tKey] & p.KEY_WAS_TRIGGERED:
                self.real_time = not self.real_time
            if fKey in keys and keys[fKey] & p.KEY_WAS_TRIGGERED:
                # generate new terain
                self.terrain.randomize(0.01)
            if jKey in keys and keys[jKey] & p.KEY_WAS_TRIGGERED:
                pos, rpy = self.get_robot_pose_rpy()
                self.reset_robot_pose_rpy(pos, (rpy[0] + math.radians(30), rpy[1], rpy[2]))
            if kKey in keys and keys[kKey] & p.KEY_WAS_TRIGGERED:
                pos, rpy = self.get_robot_pose_rpy()
                self.reset_robot_pose_rpy(pos, (rpy[0], rpy[1] + math.radians(30), rpy[2]))
            if lKey in keys and keys[lKey] & p.KEY_WAS_TRIGGERED:
                pos, rpy = self.get_robot_pose_rpy()
                self.reset_robot_pose_rpy(pos, (rpy[0], rpy[1], rpy[2] + math.radians(30)))
            if qKey in keys and keys[qKey] & p.KEY_WAS_TRIGGERED:
                pos, quat = self.get_robot_pose()
                self.reset_robot_pose((pos[0] + 0.1, pos[1], pos[2]), quat)
            if aKey in keys and keys[aKey] & p.KEY_WAS_TRIGGERED:
                pos, quat = self.get_robot_pose()
                self.reset_robot_pose((pos[0], pos[1] + 0.1, pos[2]), quat)
            if sKey in keys and keys[sKey] & p.KEY_WAS_TRIGGERED:
                pos, quat = self.get_robot_pose()
                self.reset_robot_pose((pos[0] - 0.1, pos[1], pos[2]), quat)
            if dKey in keys and keys[dKey] & p.KEY_WAS_TRIGGERED:
                pos, quat = self.get_robot_pose()
                self.reset_robot_pose((pos[0], pos[1] - 0.1, pos[2]), quat)
            # block until pause is over
            while self.paused:
                # sleep a bit to not block a whole CPU core while waiting
                sleep(0.1)
                keys = p.getKeyboardEvents()
                if spaceKey in keys and keys[spaceKey] & p.KEY_WAS_TRIGGERED:
                    self.paused = not self.paused
                if xKey in keys and keys[xKey] & p.KEY_IS_DOWN:
                    break

        if self.real_time:
            # wait till one timestep has actually passed in real time
            time.sleep(max(0, self.timestep - (time.time() - self.last_wall_time)))
        self.last_wall_time = time.time()
        self.time += self.timestep
        p.stepSimulation()
        for name, ps in self.pressure_sensors.items():
            ps.filter_step()

    def set_gravity(self, active):
        if active:
            p.setGravity(0, 0, -9.81)
        else:
            p.setGravity(0, 0, 0)
        self.gravity = active

    def set_robot_pose(self, position, orientation):
        p.resetBasePositionAndOrientation(self.robot_index, position, orientation)

    def reset_simulation(self):
        p.resetSimulation()
        self.load_models()

    def reset_robot_pose(self, position, orientation):
        # reset body pose and velocity
        p.resetBasePositionAndOrientation(self.robot_index, position, orientation)
        p.resetBaseVelocity(self.robot_index, [0, 0, 0], [0, 0, 0])
        # we need to reset all joints to, otherwise they still have velocity
        for name in self.joints:
            joint = self.joints[name]
            p.resetJointState(joint.body_index, joint.joint_index, 0, 0)

    def reset_robot_pose_rpy(self, position, rpy):
        quat = tf.transformations.quaternion_from_euler(*rpy)
        self.reset_robot_pose(position, quat)

    def get_robot_pose(self):
        (x, y, z), (qx, qy, qz, qw) = p.getBasePositionAndOrientation(self.robot_index)
        return (x, y, z), (qx, qy, qz, qw)

    def get_robot_pose_rpy(self):
        (x, y, z), (qx, qy, qz, qw) = p.getBasePositionAndOrientation(self.robot_index)
        (roll, pitch, yaw) = p.getEulerFromQuaternion((qx, qy, qz, qw))
        return (x, y, z), (roll, pitch, yaw)

    def get_link_pose(self, link_name):
        return p.getLinkState(self.robot_index, self.links[link_name])[0]

    def get_robot_velocity(self):
        # these are in world coordinate frame
        (vx, vy, vz), (vr, vp, vy) = p.getBaseVelocity(self.robot_index)
        # rotate to robot frame
        _, (x, y, z, w) = self.get_robot_pose()
        # rotation matrix
        M = quat2mat((w, x, y, z))
        # velocities as vector
        v = np.array([vr, vp, vy]).T
        angular_vel_robot_frame = np.matmul(M.T, v)
        return (vx, vy, vz), angular_vel_robot_frame

    def get_joint_names(self):
        names = []
        for name in self.joints:
            joint = self.joints[name]
            names.append(joint.name)
        return names

    def get_joint_position(self, name):
        return self.joints[name].get_position()


class Joint:
    def __init__(self, joint_index, body_index, ft=False):
        self.joint_index = joint_index
        self.body_index = body_index
        joint_info = p.getJointInfo(self.body_index, self.joint_index)
        self.name = joint_info[1].decode('utf-8')
        self.type = joint_info[2]
        self.max_force = joint_info[10]
        self.max_velocity = joint_info[11]
        self.lowerLimit = joint_info[8]
        self.upperLimit = joint_info[9]
        self.damping = joint_info[6]
        self.friction = joint_info[7]
        self.ft = ft

    def reset_position(self, position, velocity):
        p.resetJointState(self.body_index, self.joint_index, targetValue=position, targetVelocity=velocity)
        # self.disable_motor()

    def disable_motor(self):
        p.setJointMotorControl2(self.body_index, self.joint_index,
                                controlMode=p.POSITION_CONTROL, targetPosition=0, targetVelocity=0,
                                positionGain=0.1, velocityGain=0.1, force=0)

    def set_position(self, position):
        p.setJointMotorControl2(self.body_index, self.joint_index,
                                p.POSITION_CONTROL,
                                targetPosition=position, force=self.max_force - self.friction,
                                maxVelocity=self.max_velocity)

    def get_state(self):
        position, velocity, forces, applied_torque = p.getJointState(self.body_index, self.joint_index)
        return position, velocity, forces, applied_torque

    def get_position(self):
        position, velocity, forces, applied_torque = self.get_state()
        return position

    def get_velocity(self):
        position, velocity, forces, applied_torque = self.get_state()
        return velocity

    def get_applied_torque(self):
        position, velocity, forces, applied_torque = self.get_state()
        return applied_torque

    def get_torque(self):
        if self.ft:
            position, velocity, forces, applied_torque = self.get_state()
            # todo this guesses z is the correct axis, but we dont know
            return forces[5]
        else:
            print("Force Torque sensor not activated!")
            return None


class PressureSensor:
    def __init__(self, name, joint_index, body_index, cutoff, order):
        self.joint_index = joint_index
        self.name = name
        self.body_index = body_index
        nyq = 240 * 0.5  # nyquist frequency from simulation frequency
        normalized_cutoff = cutoff / nyq  # cutoff freq in hz
        self.filter_b, self.filter_a = signal.butter(order, normalized_cutoff, btype='low')
        self.filter_state = signal.lfilter_zi(self.filter_b, 1)
        self.unfiltered = 0
        self.filtered = [0]

    def filter_step(self):
        self.unfiltered = p.getJointState(self.body_index, self.joint_index)[2][2] * -1
        self.filtered, self.filter_state = signal.lfilter(self.filter_b, self.filter_a, [self.unfiltered],
                                                          zi=self.filter_state)

    def get_force(self):
        return max(self.unfiltered, 0), max(self.filtered[0], 0)
01d582601a788798518248e3fce61eaaf09d4a14
<mask token>


class Simulation:
    <mask token>
    <mask token>
    <mask token>
    <mask token>

    def set_filter_params(self, cutoff, order):
        for i in range(p.getNumJoints(self.robot_index)):
            joint_info = p.getJointInfo(self.robot_index, i)
            name = joint_info[1].decode('utf-8')
            if name in ['LLB', 'LLF', 'LRF', 'LRB', 'RLB', 'RLF', 'RRF', 'RRB'
                ]:
                self.pressure_sensors[name] = PressureSensor(name, i, self.
                    robot_index, cutoff, order)
    <mask token>

    def step(self):
        if self.gui:
            rKey = ord('r')
            nKey = ord('n')
            xKey = ord('x')
            tKey = ord('t')
            fKey = ord('f')
            spaceKey = p.B3G_SPACE
            jKey = ord('j')
            kKey = ord('k')
            lKey = ord('l')
            qKey = ord('q')
            aKey = ord('a')
            sKey = ord('s')
            dKey = ord('d')
            keys = p.getKeyboardEvents()
            if rKey in keys and keys[rKey] & p.KEY_WAS_TRIGGERED:
                self.reset()
            if spaceKey in keys and keys[spaceKey] & p.KEY_WAS_TRIGGERED:
                self.paused = not self.paused
            if nKey in keys and keys[nKey] & p.KEY_WAS_TRIGGERED:
                self.set_gravity(not self.gravity)
            if tKey in keys and keys[tKey] & p.KEY_WAS_TRIGGERED:
                self.real_time = not self.real_time
            if fKey in keys and keys[fKey] & p.KEY_WAS_TRIGGERED:
                self.terrain.randomize(0.01)
            if jKey in keys and keys[jKey] & p.KEY_WAS_TRIGGERED:
                pos, rpy = self.get_robot_pose_rpy()
                self.reset_robot_pose_rpy(pos, (rpy[0] + math.radians(30),
                    rpy[1], rpy[2]))
            if kKey in keys and keys[kKey] & p.KEY_WAS_TRIGGERED:
                pos, rpy = self.get_robot_pose_rpy()
                self.reset_robot_pose_rpy(pos, (rpy[0], rpy[1] + math.
                    radians(30), rpy[2]))
            if lKey in keys and keys[lKey] & p.KEY_WAS_TRIGGERED:
                pos, rpy = self.get_robot_pose_rpy()
                self.reset_robot_pose_rpy(pos, (rpy[0], rpy[1], rpy[2] +
                    math.radians(30)))
            if qKey in keys and keys[qKey] & p.KEY_WAS_TRIGGERED:
                pos, quat = self.get_robot_pose()
                self.reset_robot_pose((pos[0] + 0.1, pos[1], pos[2]), quat)
            if aKey in keys and keys[aKey] & p.KEY_WAS_TRIGGERED:
                pos, quat = self.get_robot_pose()
                self.reset_robot_pose((pos[0], pos[1] + 0.1, pos[2]), quat)
            if sKey in keys and keys[sKey] & p.KEY_WAS_TRIGGERED:
                pos, quat = self.get_robot_pose()
                self.reset_robot_pose((pos[0] - 0.1, pos[1], pos[2]), quat)
            if dKey in keys and keys[dKey] & p.KEY_WAS_TRIGGERED:
                pos, quat = self.get_robot_pose()
                self.reset_robot_pose((pos[0], pos[1] - 0.1, pos[2]), quat)
            while self.paused:
                sleep(0.1)
                keys = p.getKeyboardEvents()
                if spaceKey in keys and keys[spaceKey] & p.KEY_WAS_TRIGGERED:
                    self.paused = not self.paused
                if xKey in keys and keys[xKey] & p.KEY_IS_DOWN:
                    break
        if self.real_time:
            time.sleep(max(0, self.timestep - (time.time() - self.
                last_wall_time)))
        self.last_wall_time = time.time()
        self.time += self.timestep
        p.stepSimulation()
        for name, ps in self.pressure_sensors.items():
            ps.filter_step()
    <mask token>
    <mask token>
    <mask token>
    <mask token>
    <mask token>

    def get_robot_pose(self):
        (x, y, z), (qx, qy, qz, qw) = p.getBasePositionAndOrientation(self.
            robot_index)
        return (x, y, z), (qx, qy, qz, qw)
    <mask token>

    def get_link_pose(self, link_name):
        return p.getLinkState(self.robot_index, self.links[link_name])[0]
    <mask token>
    <mask token>
    <mask token>


class Joint:

    def __init__(self, joint_index, body_index, ft=False):
        self.joint_index = joint_index
        self.body_index = body_index
        joint_info = p.getJointInfo(self.body_index, self.joint_index)
        self.name = joint_info[1].decode('utf-8')
        self.type = joint_info[2]
        self.max_force = joint_info[10]
        self.max_velocity = joint_info[11]
        self.lowerLimit = joint_info[8]
        self.upperLimit = joint_info[9]
        self.damping = joint_info[6]
        self.friction = joint_info[7]
        self.ft = ft

    def reset_position(self, position, velocity):
        p.resetJointState(self.body_index, self.joint_index, targetValue=
            position, targetVelocity=velocity)

    def disable_motor(self):
        p.setJointMotorControl2(self.body_index, self.joint_index,
            controlMode=p.POSITION_CONTROL, targetPosition=0,
            targetVelocity=0, positionGain=0.1, velocityGain=0.1, force=0)

    def set_position(self, position):
        p.setJointMotorControl2(self.body_index, self.joint_index, p.
            POSITION_CONTROL, targetPosition=position, force=self.max_force -
            self.friction, maxVelocity=self.max_velocity)

    def get_state(self):
        position, velocity, forces, applied_torque = p.getJointState(self.
            body_index, self.joint_index)
        return position, velocity, forces, applied_torque

    def get_position(self):
        position, velocity, forces, applied_torque = self.get_state()
        return position

    def get_velocity(self):
        position, velocity, forces, applied_torque = self.get_state()
        return velocity

    def get_applied_torque(self):
        position, velocity, forces, applied_torque = self.get_state()
        return applied_torque

    def get_torque(self):
        if self.ft:
            position, velocity, forces, applied_torque = self.get_state()
            return forces[5]
        else:
            print('Force Torque sensor not activated!')
            return None


class PressureSensor:

    def __init__(self, name, joint_index, body_index, cutoff, order):
        self.joint_index = joint_index
        self.name = name
        self.body_index = body_index
        nyq = 240 * 0.5
        normalized_cutoff = cutoff / nyq
        self.filter_b, self.filter_a = signal.butter(order,
            normalized_cutoff, btype='low')
        self.filter_state = signal.lfilter_zi(self.filter_b, 1)
        self.unfiltered = 0
        self.filtered = [0]

    def filter_step(self):
        self.unfiltered = p.getJointState(self.body_index, self.joint_index)[2
            ][2] * -1
        self.filtered, self.filter_state = signal.lfilter(self.filter_b,
            self.filter_a, [self.unfiltered], zi=self.filter_state)

    def get_force(self):
        return max(self.unfiltered, 0), max(self.filtered[0], 0)

<mask token>


class Simulation:
    <mask token>

    def load_models(self):
        print('load models')
        self.terrain_index = None
        self.plane_index = None
        if self.terrain_on:
            self.max_terrain_height = 0.01
            self.terrain = Terrain(self.max_terrain_height)
            self.terrain_index = self.terrain.id
        else:
            p.setAdditionalSearchPath(pybullet_data.getDataPath())
            self.plane_index = p.loadURDF('plane.urdf')
        self.field_index = None
        if self.field_on:
            rospack = rospkg.RosPack()
            path = os.path.join(rospack.get_path('wolfgang_pybullet_sim'),
                'models')
            p.setAdditionalSearchPath(path)
            self.field_index = p.loadURDF('field/field.urdf')
        if self.robot in ['wolfgang', 'sigmaban']:
            flags = p.URDF_USE_SELF_COLLISION + p.URDF_USE_INERTIA_FROM_FILE
        else:
            flags = p.URDF_USE_SELF_COLLISION
        if self.urdf_path is None:
            rospack = rospkg.RosPack()
            if self.robot == 'op2':
                self.urdf_path = rospack.get_path('robotis_op2_description'
                    ) + '/urdf/robot.urdf'
            elif self.robot == 'sigmaban':
                self.urdf_path = rospack.get_path('sigmaban_description'
                    ) + '/urdf/robot.urdf'
            else:
                self.urdf_path = rospack.get_path('wolfgang_description'
                    ) + '/urdf/robot.urdf'
        self.robot_index = p.loadURDF(self.urdf_path, self.start_position,
            self.start_orientation, flags=flags)
        self.joints = {}
        self.pressure_sensors = {}
        self.links = {}
        link_index = 0
        for i in range(p.getNumJoints(self.robot_index)):
            joint_info = p.getJointInfo(self.robot_index, i)
            name = joint_info[1].decode('utf-8')
            type = joint_info[2]
            self.links[joint_info[12].decode('utf-8')] = link_index
            link_index += 1
            if type == 0:
                if self.joints_ft:
                    p.enableJointForceTorqueSensor(self.robot_index, i)
                self.joints[name] = Joint(i, self.robot_index, ft=self.
                    joints_ft)
            elif name in ['LLB', 'LLF', 'LRF', 'LRB', 'RLB', 'RLF', 'RRF',
                'RRB']:
                p.enableJointForceTorqueSensor(self.robot_index, i)
                self.pressure_sensors[name] = PressureSensor(name, i, self.
                    robot_index, 10, 5)
        for linkA in self.links.keys():
            for linkB in self.links.keys():
                p.setCollisionFilterPair(self.robot_index, self.robot_index,
                    self.links[linkA], self.links[linkB], 0)
        hip_group = []
        foot_group = []
        if self.robot in ('wolfgang', 'op2', 'robotis_op2'):
            hip_group = ['torso', 'r_hip_1', 'r_hip_2', 'l_hip_1', 'l_hip_2']
            foot_group = ['r_ankle', 'r_foot', 'l_ankle', 'l_foot']
        elif self.robot in 'sigmaban':
            hip_group = ['mx106_block_mir_1', 'u_block_1', 'right_knee_1',
                'left_knee_1', 'mx106_block_2', 'u_block_2']
            foot_group = ['tibia_1', 'mx106_block_1',
                'right_foot_cleat_back_left', 'mx106_block_mir_2',
                'left_foot_cleat_front_right', 'tibia_2']
        for hip_link_index in hip_group:
            for foot_link_index in foot_group:
                p.setCollisionFilterPair(self.robot_index, self.robot_index,
                    self.links[hip_link_index], self.links[foot_link_index], 1)
        self.reset()
    <mask token>
    <mask token>

    def set_filter_params(self, cutoff, order):
        for i in range(p.getNumJoints(self.robot_index)):
            joint_info = p.getJointInfo(self.robot_index, i)
            name = joint_info[1].decode('utf-8')
            if name in ['LLB', 'LLF', 'LRF', 'LRB', 'RLB', 'RLF', 'RRF', 'RRB'
                ]:
                self.pressure_sensors[name] = PressureSensor(name, i, self.
                    robot_index, cutoff, order)
    <mask token>

    def step(self):
        if self.gui:
            rKey = ord('r')
            nKey = ord('n')
            xKey = ord('x')
            tKey = ord('t')
            fKey = ord('f')
            spaceKey = p.B3G_SPACE
            jKey = ord('j')
            kKey = ord('k')
            lKey = ord('l')
            qKey = ord('q')
            aKey = ord('a')
            sKey = ord('s')
            dKey = ord('d')
            keys = p.getKeyboardEvents()
            if rKey in keys and keys[rKey] & p.KEY_WAS_TRIGGERED:
                self.reset()
            if spaceKey in keys and keys[spaceKey] & p.KEY_WAS_TRIGGERED:
                self.paused = not self.paused
            if nKey in keys and keys[nKey] & p.KEY_WAS_TRIGGERED:
                self.set_gravity(not self.gravity)
            if tKey in keys and keys[tKey] & p.KEY_WAS_TRIGGERED:
                self.real_time = not self.real_time
            if fKey in keys and keys[fKey] & p.KEY_WAS_TRIGGERED:
                self.terrain.randomize(0.01)
            if jKey in keys and keys[jKey] & p.KEY_WAS_TRIGGERED:
                pos, rpy = self.get_robot_pose_rpy()
                self.reset_robot_pose_rpy(pos, (rpy[0] + math.radians(30),
                    rpy[1], rpy[2]))
            if kKey in keys and keys[kKey] & p.KEY_WAS_TRIGGERED:
                pos, rpy = self.get_robot_pose_rpy()
                self.reset_robot_pose_rpy(pos, (rpy[0], rpy[1] + math.
                    radians(30), rpy[2]))
            if lKey in keys and keys[lKey] & p.KEY_WAS_TRIGGERED:
                pos, rpy = self.get_robot_pose_rpy()
                self.reset_robot_pose_rpy(pos, (rpy[0], rpy[1], rpy[2] +
                    math.radians(30)))
            if qKey in keys and keys[qKey] & p.KEY_WAS_TRIGGERED:
                pos, quat = self.get_robot_pose()
                self.reset_robot_pose((pos[0] + 0.1, pos[1], pos[2]), quat)
            if aKey in keys and keys[aKey] & p.KEY_WAS_TRIGGERED:
                pos, quat = self.get_robot_pose()
                self.reset_robot_pose((pos[0], pos[1] + 0.1, pos[2]), quat)
            if sKey in keys and keys[sKey] & p.KEY_WAS_TRIGGERED:
                pos, quat = self.get_robot_pose()
                self.reset_robot_pose((pos[0] - 0.1, pos[1], pos[2]), quat)
            if dKey in keys and keys[dKey] & p.KEY_WAS_TRIGGERED:
                pos, quat = self.get_robot_pose()
                self.reset_robot_pose((pos[0], pos[1] - 0.1, pos[2]), quat)
            while self.paused:
                sleep(0.1)
                keys = p.getKeyboardEvents()
                if spaceKey in keys and keys[spaceKey] & p.KEY_WAS_TRIGGERED:
                    self.paused = not self.paused
                if xKey in keys and keys[xKey] & p.KEY_IS_DOWN:
                    break
        if self.real_time:
            time.sleep(max(0, self.timestep - (time.time() - self.
                last_wall_time)))
        self.last_wall_time = time.time()
        self.time += self.timestep
        p.stepSimulation()
        for name, ps in self.pressure_sensors.items():
            ps.filter_step()
    <mask token>

    def set_robot_pose(self, position, orientation):
        p.resetBasePositionAndOrientation(self.robot_index, position,
            orientation)
    <mask token>
    <mask token>
    <mask token>

    def get_robot_pose(self):
        (x, y, z), (qx, qy, qz, qw) = p.getBasePositionAndOrientation(self.
            robot_index)
        return (x, y, z), (qx, qy, qz, qw)
    <mask token>

    def get_link_pose(self, link_name):
        return p.getLinkState(self.robot_index, self.links[link_name])[0]
    <mask token>
    <mask token>
    <mask token>


class Joint:

    def __init__(self, joint_index, body_index, ft=False):
        self.joint_index = joint_index
        self.body_index = body_index
        joint_info = p.getJointInfo(self.body_index, self.joint_index)
        self.name = joint_info[1].decode('utf-8')
        self.type = joint_info[2]
        self.max_force = joint_info[10]
        self.max_velocity = joint_info[11]
        self.lowerLimit = joint_info[8]
        self.upperLimit = joint_info[9]
        self.damping = joint_info[6]
        self.friction = joint_info[7]
        self.ft = ft

    def reset_position(self, position, velocity):
        p.resetJointState(self.body_index, self.joint_index, targetValue=
            position, targetVelocity=velocity)

    def disable_motor(self):
        p.setJointMotorControl2(self.body_index, self.joint_index,
            controlMode=p.POSITION_CONTROL, targetPosition=0,
            targetVelocity=0, positionGain=0.1, velocityGain=0.1, force=0)

    def set_position(self, position):
        p.setJointMotorControl2(self.body_index, self.joint_index, p.
            POSITION_CONTROL, targetPosition=position, force=self.max_force -
            self.friction, maxVelocity=self.max_velocity)

    def get_state(self):
        position, velocity, forces, applied_torque = p.getJointState(self.
            body_index, self.joint_index)
        return position, velocity, forces, applied_torque

    def get_position(self):
        position, velocity, forces, applied_torque = self.get_state()
        return position

    def get_velocity(self):
        position, velocity, forces, applied_torque = self.get_state()
        return velocity

    def get_applied_torque(self):
        position, velocity, forces, applied_torque = self.get_state()
        return applied_torque

    def get_torque(self):
        if self.ft:
            position, velocity, forces, applied_torque = self.get_state()
            return forces[5]
        else:
            print('Force Torque sensor not activated!')
            return None


class PressureSensor:

    def __init__(self, name, joint_index, body_index, cutoff, order):
        self.joint_index = joint_index
        self.name = name
        self.body_index = body_index
        nyq = 240 * 0.5
        normalized_cutoff = cutoff / nyq
        self.filter_b, self.filter_a = signal.butter(order,
            normalized_cutoff, btype='low')
        self.filter_state = signal.lfilter_zi(self.filter_b, 1)
        self.unfiltered = 0
        self.filtered = [0]

    def filter_step(self):
        self.unfiltered = p.getJointState(self.body_index, self.joint_index)[2
            ][2] * -1
        self.filtered, self.filter_state = signal.lfilter(self.filter_b,
            self.filter_a, [self.unfiltered], zi=self.filter_state)

    def get_force(self):
        return max(self.unfiltered, 0), max(self.filtered[0], 0)

<mask token>


class Simulation:
    <mask token>

    def load_models(self):
        print('load models')
        self.terrain_index = None
        self.plane_index = None
        if self.terrain_on:
            self.max_terrain_height = 0.01
            self.terrain = Terrain(self.max_terrain_height)
            self.terrain_index = self.terrain.id
        else:
            p.setAdditionalSearchPath(pybullet_data.getDataPath())
            self.plane_index = p.loadURDF('plane.urdf')
        self.field_index = None
        if self.field_on:
            rospack = rospkg.RosPack()
            path = os.path.join(rospack.get_path('wolfgang_pybullet_sim'),
                'models')
            p.setAdditionalSearchPath(path)
            self.field_index = p.loadURDF('field/field.urdf')
        if self.robot in ['wolfgang', 'sigmaban']:
            flags = p.URDF_USE_SELF_COLLISION + p.URDF_USE_INERTIA_FROM_FILE
        else:
            flags = p.URDF_USE_SELF_COLLISION
        if self.urdf_path is None:
            rospack = rospkg.RosPack()
            if self.robot == 'op2':
                self.urdf_path = rospack.get_path('robotis_op2_description'
                    ) + '/urdf/robot.urdf'
            elif self.robot == 'sigmaban':
                self.urdf_path = rospack.get_path('sigmaban_description'
                    ) + '/urdf/robot.urdf'
            else:
                self.urdf_path = rospack.get_path('wolfgang_description'
                    ) + '/urdf/robot.urdf'
        self.robot_index = p.loadURDF(self.urdf_path, self.start_position,
            self.start_orientation, flags=flags)
        self.joints = {}
        self.pressure_sensors = {}
        self.links = {}
        link_index = 0
        for i in range(p.getNumJoints(self.robot_index)):
            joint_info = p.getJointInfo(self.robot_index, i)
            name = joint_info[1].decode('utf-8')
            type = joint_info[2]
            self.links[joint_info[12].decode('utf-8')] = link_index
            link_index += 1
            if type == 0:
                if self.joints_ft:
                    p.enableJointForceTorqueSensor(self.robot_index, i)
                self.joints[name] = Joint(i, self.robot_index, ft=self.
                    joints_ft)
            elif name in ['LLB', 'LLF', 'LRF', 'LRB', 'RLB', 'RLF', 'RRF',
                'RRB']:
                p.enableJointForceTorqueSensor(self.robot_index, i)
                self.pressure_sensors[name] = PressureSensor(name, i, self.
                    robot_index, 10, 5)
        for linkA in self.links.keys():
            for linkB in self.links.keys():
                p.setCollisionFilterPair(self.robot_index, self.robot_index,
                    self.links[linkA], self.links[linkB], 0)
        hip_group = []
        foot_group = []
        if self.robot in ('wolfgang', 'op2', 'robotis_op2'):
            hip_group = ['torso', 'r_hip_1', 'r_hip_2', 'l_hip_1', 'l_hip_2']
            foot_group = ['r_ankle', 'r_foot', 'l_ankle', 'l_foot']
        elif self.robot in 'sigmaban':
            hip_group = ['mx106_block_mir_1', 'u_block_1', 'right_knee_1',
                'left_knee_1', 'mx106_block_2', 'u_block_2']
            foot_group = ['tibia_1', 'mx106_block_1',
                'right_foot_cleat_back_left', 'mx106_block_mir_2',
                'left_foot_cleat_front_right', 'tibia_2']
        for hip_link_index in hip_group:
            for foot_link_index in foot_group:
                p.setCollisionFilterPair(self.robot_index, self.robot_index,
                    self.links[hip_link_index], self.links[foot_link_index], 1)
        self.reset()

    def apply_force(self, link_id, force, position):
        """
        Applies an external force to a position on a link.
        :param link_id: link index or -1 for base link (int)
        :param force: direction and amount of applied force (vec3)
        :param position: where on the link the force should be applied (vec3)
        """
        p.applyExternalForce(self.robot_index, link_id, force, position,
            flags=p.WORLD_FRAME)

    def set_foot_dynamics(self, contact_damping, contact_stiffness,
        joint_damping, lateral_friction=1, spinning_friction=1,
        rolling_friction=1, restitution=0):
        for link_name in self.links.keys():
            if link_name in ['llb', 'llf', 'lrf', 'lrb', 'rlb', 'rlf',
                'rrf', 'rrb'] or link_name in self.foot_link_names:
                p.changeDynamics(self.robot_index, self.links[link_name],
                    lateralFriction=lateral_friction, spinningFriction=
                    spinning_friction, rollingFriction=rolling_friction,
                    contactDamping=contact_damping, contactStiffness=
                    contact_stiffness, jointDamping=joint_damping,
                    restitution=restitution)
        if self.plane_index:
            p.changeDynamics(self.plane_index, -1, lateralFriction=
                lateral_friction, spinningFriction=spinning_friction,
                rollingFriction=rolling_friction, restitution=restitution,
                contactDamping=contact_damping, contactStiffness=
                contact_stiffness, jointDamping=joint_damping)
        if self.field_index:
            p.changeDynamics(self.field_index, -1, lateralFriction=
                lateral_friction, spinningFriction=spinning_friction,
                rollingFriction=rolling_friction, restitution=restitution,
                contactDamping=contact_damping, contactStiffness=
                contact_stiffness, jointDamping=joint_damping)
        if self.terrain_index:
            p.changeDynamics(self.terrain_index, -1, lateralFriction=
                lateral_friction, spinningFriction=spinning_friction,
                rollingFriction=rolling_friction, restitution=restitution,
                contactDamping=contact_damping, contactStiffness=
                contact_stiffness, jointDamping=joint_damping)

    def set_filter_params(self, cutoff, order):
        for i in range(p.getNumJoints(self.robot_index)):
            joint_info = p.getJointInfo(self.robot_index, i)
            name = joint_info[1].decode('utf-8')
            if name in ['LLB', 'LLF', 'LRF', 'LRB', 'RLB', 'RLF', 'RRF', 'RRB'
                ]:
                self.pressure_sensors[name] = PressureSensor(name, i, self.
                    robot_index, cutoff, order)

    def reset(self):
        for name in self.joints:
            joint = self.joints[name]
            try:
                pos_in_rad = math.radians(self.initial_joints_positions[name])
            except KeyError:
                pos_in_rad = 0
            joint.reset_position(pos_in_rad, 0)
            joint.set_position(pos_in_rad)
        p.resetBasePositionAndOrientation(self.robot_index, self.
            start_position, self.start_orientation)
        p.resetBaseVelocity(self.robot_index, [0, 0, 0], [0, 0, 0])

    def step(self):
        if self.gui:
            rKey = ord('r')
            nKey = ord('n')
            xKey = ord('x')
            tKey = ord('t')
            fKey = ord('f')
            spaceKey = p.B3G_SPACE
            jKey = ord('j')
            kKey = ord('k')
            lKey = ord('l')
            qKey = ord('q')
            aKey = ord('a')
            sKey = ord('s')
            dKey = ord('d')
            keys = p.getKeyboardEvents()
            if rKey in keys and keys[rKey] & p.KEY_WAS_TRIGGERED:
                self.reset()
            if spaceKey in keys and keys[spaceKey] & p.KEY_WAS_TRIGGERED:
                self.paused = not self.paused
            if nKey in keys and keys[nKey] & p.KEY_WAS_TRIGGERED:
                self.set_gravity(not self.gravity)
            if tKey in keys and keys[tKey] & p.KEY_WAS_TRIGGERED:
                self.real_time = not self.real_time
            if fKey in keys and keys[fKey] & p.KEY_WAS_TRIGGERED:
                self.terrain.randomize(0.01)
            if jKey in keys and keys[jKey] & p.KEY_WAS_TRIGGERED:
                pos, rpy = self.get_robot_pose_rpy()
                self.reset_robot_pose_rpy(pos, (rpy[0] + math.radians(30),
                    rpy[1], rpy[2]))
            if kKey in keys and keys[kKey] & p.KEY_WAS_TRIGGERED:
                pos, rpy = self.get_robot_pose_rpy()
                self.reset_robot_pose_rpy(pos, (rpy[0], rpy[1] + math.
                    radians(30), rpy[2]))
            if lKey in keys and keys[lKey] & p.KEY_WAS_TRIGGERED:
                pos, rpy = self.get_robot_pose_rpy()
                self.reset_robot_pose_rpy(pos, (rpy[0], rpy[1], rpy[2] +
                    math.radians(30)))
            if qKey in keys and keys[qKey] & p.KEY_WAS_TRIGGERED:
                pos, quat = self.get_robot_pose()
                self.reset_robot_pose((pos[0] + 0.1, pos[1], pos[2]), quat)
            if aKey in keys and keys[aKey] & p.KEY_WAS_TRIGGERED:
                pos, quat = self.get_robot_pose()
                self.reset_robot_pose((pos[0], pos[1] + 0.1, pos[2]), quat)
            if sKey in keys and keys[sKey] & p.KEY_WAS_TRIGGERED:
                pos, quat = self.get_robot_pose()
                self.reset_robot_pose((pos[0] - 0.1, pos[1], pos[2]), quat)
            if dKey in keys and keys[dKey] & p.KEY_WAS_TRIGGERED:
                pos, quat = self.get_robot_pose()
                self.reset_robot_pose((pos[0], pos[1] - 0.1, pos[2]), quat)
            while self.paused:
                sleep(0.1)
                keys = p.getKeyboardEvents()
                if spaceKey in keys and keys[spaceKey] & p.KEY_WAS_TRIGGERED:
                    self.paused = not self.paused
                if xKey in keys and keys[xKey] & p.KEY_IS_DOWN:
                    break
        if self.real_time:
            time.sleep(max(0, self.timestep - (time.time() - self.
                last_wall_time)))
        self.last_wall_time = time.time()
        self.time += self.timestep
        p.stepSimulation()
        for name, ps in self.pressure_sensors.items():
            ps.filter_step()

    def set_gravity(self, active):
        if active:
            p.setGravity(0, 0, -9.81)
        else:
            p.setGravity(0, 0, 0)
        self.gravity = active

    def set_robot_pose(self, position, orientation):
        p.resetBasePositionAndOrientation(self.robot_index, position,
            orientation)

    def reset_simulation(self):
        p.resetSimulation()
        self.load_models()
    <mask token>

    def reset_robot_pose_rpy(self, position, rpy):
        quat = tf.transformations.quaternion_from_euler(*rpy)
        self.reset_robot_pose(position, quat)

    def get_robot_pose(self):
        (x, y, z), (qx, qy, qz, qw) = p.getBasePositionAndOrientation(self.
            robot_index)
        return (x, y, z), (qx, qy, qz, qw)
    <mask token>

    def get_link_pose(self, link_name):
        return p.getLinkState(self.robot_index, self.links[link_name])[0]
    <mask token>
    <mask token>
    <mask token>


class Joint:

    def __init__(self, joint_index, body_index, ft=False):
        self.joint_index = joint_index
        self.body_index = body_index
        joint_info = p.getJointInfo(self.body_index, self.joint_index)
        self.name = joint_info[1].decode('utf-8')
        self.type = joint_info[2]
        self.max_force = joint_info[10]
        self.max_velocity = joint_info[11]
        self.lowerLimit = joint_info[8]
        self.upperLimit = joint_info[9]
        self.damping = joint_info[6]
        self.friction = joint_info[7]
        self.ft = ft

    def reset_position(self, position, velocity):
        p.resetJointState(self.body_index, self.joint_index, targetValue=
            position, targetVelocity=velocity)

    def disable_motor(self):
        p.setJointMotorControl2(self.body_index, self.joint_index,
            controlMode=p.POSITION_CONTROL, targetPosition=0,
            targetVelocity=0, positionGain=0.1, velocityGain=0.1, force=0)

    def set_position(self, position):
        p.setJointMotorControl2(self.body_index, self.joint_index, p.
            POSITION_CONTROL, targetPosition=position, force=self.max_force -
            self.friction, maxVelocity=self.max_velocity)

    def get_state(self):
        position, velocity, forces, applied_torque = p.getJointState(self.
            body_index, self.joint_index)
        return position, velocity, forces, applied_torque

    def get_position(self):
        position, velocity, forces, applied_torque = self.get_state()
        return position

    def get_velocity(self):
        position, velocity, forces, applied_torque = self.get_state()
        return velocity

    def get_applied_torque(self):
        position, velocity, forces, applied_torque = self.get_state()
        return applied_torque

    def get_torque(self):
        if self.ft:
            position, velocity, forces, applied_torque = self.get_state()
            return forces[5]
        else:
            print('Force Torque sensor not activated!')
            return None


class PressureSensor:

    def __init__(self, name, joint_index, body_index, cutoff, order):
        self.joint_index = joint_index
        self.name = name
        self.body_index = body_index
        nyq = 240 * 0.5
        normalized_cutoff = cutoff / nyq
        self.filter_b, self.filter_a = signal.butter(order,
            normalized_cutoff, btype='low')
        self.filter_state = signal.lfilter_zi(self.filter_b, 1)
        self.unfiltered = 0
        self.filtered = [0]

    def filter_step(self):
        self.unfiltered = p.getJointState(self.body_index, self.joint_index)[2
            ][2] * -1
        self.filtered, self.filter_state = signal.lfilter(self.filter_b,
            self.filter_a, [self.unfiltered], zi=self.filter_state)

    def get_force(self):
        return max(self.unfiltered, 0), max(self.filtered[0], 0)

<mask token>


class Simulation:

    def __init__(self, gui, urdf_path=None, foot_link_names=[], terrain=
        False, field=True, joints_ft=False, robot='wolfgang'):
        self.gui = gui
        self.paused = False
        self.gravity = True
        self.terrain_on = terrain
        self.field_on = field
        self.urdf_path = urdf_path
        self.foot_link_names = foot_link_names
        self.joints_ft = joints_ft
        self.robot = robot
        self.start_position = [0, 0, 0.43]
        self.start_orientation = p.getQuaternionFromEuler((0, 0.25, 0))
        if self.robot == 'wolfgang':
            self.initial_joints_positions = {'LAnklePitch': -30,
                'LAnkleRoll': 0, 'LHipPitch': 30, 'LHipRoll': 0, 'LHipYaw':
                0, 'LKnee': 60, 'RAnklePitch': 30, 'RAnkleRoll': 0,
                'RHipPitch': -30, 'RHipRoll': 0, 'RHipYaw': 0, 'RKnee': -60,
                'LShoulderPitch': 0, 'LShoulderRoll': 0, 'LElbow': 45,
                'RShoulderPitch': 0, 'RShoulderRoll': 0, 'RElbow': -45,
                'HeadPan': 0, 'HeadTilt': 0}
        elif self.robot in ['op2', 'robotis_op2']:
            self.initial_joints_positions = {'l_ankle_pitch': 0,
                'l_ankle_roll': 0, 'l_hip_pitch': 0, 'l_hip_roll': 0,
                'l_hip_yaw': 0, 'l_knee': 0, 'r_ankle_pitch': 0,
                'r_ankle_roll': 0, 'r_hip_pitch': 0, 'r_hip_roll': 0,
                'r_hip_yaw': 0, 'r_knee': 0, 'l_sho_pitch': 0, 'l_sho_roll':
                0, 'LElbow': 0, 'r_sho_pitch': 0, 'r_sho_roll': 0, 'RElbow':
                0, 'head_pan': 0, 'head_tilt': 0}
            self.foot_link_names = ['l_foot', 'r_foot']
        elif self.robot == 'sigmaban':
            self.start_orientation = p.getQuaternionFromEuler((0, 0.0, 0))
            self.initial_joints_positions = {'left_ankle_pitch': 0,
                'left_ankle_roll': 0, 'left_hip_pitch': 0, 'left_hip_roll':
                0, 'left_hip_yaw': 0, 'left_knee': 0, 'right_ankle_pitch': 
                0, 'right_ankle_roll': 0, 'right_hip_pitch': 0,
                'right_hip_roll': 0, 'right_hip_yaw': 0, 'right_knee': 0,
                'left_shoulder_pitch': 0, 'left_shoulder_roll': 0, 'LElbow':
                0, 'right_shoulder_pitch': 0, 'right_shoulder_roll': 0,
                'RElbow': 0, 'head_yaw': 0, 'head_pitch': 0}
        else:
            print(f'robot {self.robot} not known')
            quit(0)
        if self.gui:
            self.client_id = p.connect(p.GUI)
        else:
            self.client_id = p.connect(p.DIRECT)
        if self.gravity:
            p.setGravity(0, 0, -9.81)
        self.time = 0
        p.configureDebugVisualizer(p.COV_ENABLE_GUI, False)
        self.timestep = 1 / 240
        self.real_time = False
        p.setRealTimeSimulation(0)
        self.last_wall_time = time.time()
        self.load_models()

    def load_models(self):
        print('load models')
        self.terrain_index = None
        self.plane_index = None
        if self.terrain_on:
            self.max_terrain_height = 0.01
            self.terrain = Terrain(self.max_terrain_height)
            self.terrain_index = self.terrain.id
        else:
            p.setAdditionalSearchPath(pybullet_data.getDataPath())
            self.plane_index = p.loadURDF('plane.urdf')
        self.field_index = None
        if self.field_on:
            rospack = rospkg.RosPack()
            path = os.path.join(rospack.get_path('wolfgang_pybullet_sim'),
                'models')
            p.setAdditionalSearchPath(path)
            self.field_index = p.loadURDF('field/field.urdf')
        if self.robot in ['wolfgang', 'sigmaban']:
            flags = p.URDF_USE_SELF_COLLISION + p.URDF_USE_INERTIA_FROM_FILE
        else:
            flags = p.URDF_USE_SELF_COLLISION
        if self.urdf_path is None:
            rospack = rospkg.RosPack()
            if self.robot == 'op2':
                self.urdf_path = rospack.get_path('robotis_op2_description'
                    ) + '/urdf/robot.urdf'
            elif self.robot == 'sigmaban':
                self.urdf_path = rospack.get_path('sigmaban_description'
                    ) + '/urdf/robot.urdf'
            else:
                self.urdf_path = rospack.get_path('wolfgang_description'
                    ) + '/urdf/robot.urdf'
        self.robot_index = p.loadURDF(self.urdf_path, self.start_position,
            self.start_orientation, flags=flags)
        self.joints = {}
        self.pressure_sensors = {}
        self.links = {}
        link_index = 0
        for i in range(p.getNumJoints(self.robot_index)):
            joint_info = p.getJointInfo(self.robot_index, i)
            name = joint_info[1].decode('utf-8')
            type = joint_info[2]
            self.links[joint_info[12].decode('utf-8')] = link_index
            link_index += 1
            if type == 0:
                if self.joints_ft:
                    p.enableJointForceTorqueSensor(self.robot_index, i)
                self.joints[name] = Joint(i, self.robot_index, ft=self.
                    joints_ft)
            elif name in ['LLB', 'LLF', 'LRF', 'LRB', 'RLB', 'RLF', 'RRF',
                'RRB']:
                p.enableJointForceTorqueSensor(self.robot_index, i)
                self.pressure_sensors[name] = PressureSensor(name, i, self.
                    robot_index, 10, 5)
        for linkA in self.links.keys():
            for linkB in self.links.keys():
                p.setCollisionFilterPair(self.robot_index, self.robot_index,
                    self.links[linkA], self.links[linkB], 0)
        hip_group = []
        foot_group = []
        if self.robot in ('wolfgang', 'op2', 'robotis_op2'):
            hip_group = ['torso', 'r_hip_1', 'r_hip_2', 'l_hip_1', 'l_hip_2']
            foot_group = ['r_ankle', 'r_foot', 'l_ankle', 'l_foot']
        elif self.robot in 'sigmaban':
            hip_group = ['mx106_block_mir_1', 'u_block_1', 'right_knee_1',
                'left_knee_1', 'mx106_block_2', 'u_block_2']
            foot_group = ['tibia_1', 'mx106_block_1',
                'right_foot_cleat_back_left', 'mx106_block_mir_2',
                'left_foot_cleat_front_right', 'tibia_2']
        for hip_link_index in hip_group:
            for foot_link_index in foot_group:
                p.setCollisionFilterPair(self.robot_index, self.robot_index,
                    self.links[hip_link_index], self.links[foot_link_index], 1)
        self.reset()

    def apply_force(self, link_id, force, position):
        """
        Applies an external force to a position on a link.
        :param link_id: link index or -1 for base link (int)
        :param force: direction and amount of applied force (vec3)
        :param position: where on the link the force should be applied (vec3)
        """
        p.applyExternalForce(self.robot_index, link_id, force, position,
            flags=p.WORLD_FRAME)

    def set_foot_dynamics(self, contact_damping, contact_stiffness,
        joint_damping, lateral_friction=1, spinning_friction=1,
        rolling_friction=1, restitution=0):
        for link_name in self.links.keys():
            if link_name in ['llb', 'llf', 'lrf', 'lrb', 'rlb', 'rlf',
                'rrf', 'rrb'] or link_name in self.foot_link_names:
                p.changeDynamics(self.robot_index, self.links[link_name],
                    lateralFriction=lateral_friction, spinningFriction=
                    spinning_friction, rollingFriction=rolling_friction,
                    contactDamping=contact_damping, contactStiffness=
                    contact_stiffness, jointDamping=joint_damping,
                    restitution=restitution)
        if self.plane_index:
            p.changeDynamics(self.plane_index, -1, lateralFriction=
                lateral_friction, spinningFriction=spinning_friction,
                rollingFriction=rolling_friction, restitution=restitution,
                contactDamping=contact_damping, contactStiffness=
                contact_stiffness, jointDamping=joint_damping)
        if self.field_index:
            p.changeDynamics(self.field_index, -1, lateralFriction=
                lateral_friction, spinningFriction=spinning_friction,
                rollingFriction=rolling_friction, restitution=restitution,
                contactDamping=contact_damping, contactStiffness=
                contact_stiffness, jointDamping=joint_damping)
        if self.terrain_index:
            p.changeDynamics(self.terrain_index, -1, lateralFriction=
                lateral_friction, spinningFriction=spinning_friction,
                rollingFriction=rolling_friction, restitution=restitution,
                contactDamping=contact_damping, contactStiffness=
                contact_stiffness, jointDamping=joint_damping)

    def set_filter_params(self, cutoff, order):
        for i in range(p.getNumJoints(self.robot_index)):
            joint_info = p.getJointInfo(self.robot_index, i)
            name = joint_info[1].decode('utf-8')
            if name in ['LLB', 'LLF', 'LRF', 'LRB', 'RLB', 'RLF', 'RRF', 'RRB'
                ]:
                self.pressure_sensors[name] = PressureSensor(name, i, self.
                    robot_index, cutoff, order)

    def reset(self):
        for name in self.joints:
            joint = self.joints[name]
            try:
                pos_in_rad = math.radians(self.initial_joints_positions[name])
            except KeyError:
                pos_in_rad = 0
            joint.reset_position(pos_in_rad, 0)
            joint.set_position(pos_in_rad)
        p.resetBasePositionAndOrientation(self.robot_index, self.
            start_position, self.start_orientation)
        p.resetBaseVelocity(self.robot_index, [0, 0, 0], [0, 0, 0])

    def step(self):
        if self.gui:
            rKey = ord('r')
            nKey = ord('n')
            xKey = ord('x')
            tKey = ord('t')
            fKey = ord('f')
            spaceKey = p.B3G_SPACE
            jKey = ord('j')
            kKey = ord('k')
            lKey = ord('l')
            qKey = ord('q')
            aKey = ord('a')
            sKey = ord('s')
            dKey = ord('d')
            keys = p.getKeyboardEvents()
            if rKey in keys and keys[rKey] & p.KEY_WAS_TRIGGERED:
                self.reset()
            if spaceKey in keys and keys[spaceKey] & p.KEY_WAS_TRIGGERED:
                self.paused = not self.paused
            if nKey in keys and keys[nKey] & p.KEY_WAS_TRIGGERED:
                self.set_gravity(not self.gravity)
            if tKey in keys and keys[tKey] & p.KEY_WAS_TRIGGERED:
                self.real_time = not self.real_time
            if fKey in keys and keys[fKey] & p.KEY_WAS_TRIGGERED:
                self.terrain.randomize(0.01)
            if jKey in keys and keys[jKey] & p.KEY_WAS_TRIGGERED:
                pos, rpy = self.get_robot_pose_rpy()
                self.reset_robot_pose_rpy(pos, (rpy[0] + math.radians(30),
                    rpy[1], rpy[2]))
            if kKey in keys and keys[kKey] & p.KEY_WAS_TRIGGERED:
                pos, rpy = self.get_robot_pose_rpy()
                self.reset_robot_pose_rpy(pos, (rpy[0], rpy[1] + math.
                    radians(30), rpy[2]))
            if lKey in keys and keys[lKey] & p.KEY_WAS_TRIGGERED:
                pos, rpy = self.get_robot_pose_rpy()
                self.reset_robot_pose_rpy(pos, (rpy[0], rpy[1], rpy[2] +
                    math.radians(30)))
            if qKey in keys and keys[qKey] & p.KEY_WAS_TRIGGERED:
                pos, quat = self.get_robot_pose()
                self.reset_robot_pose((pos[0] + 0.1, pos[1], pos[2]), quat)
            if aKey in keys and keys[aKey] & p.KEY_WAS_TRIGGERED:
                pos, quat = self.get_robot_pose()
                self.reset_robot_pose((pos[0], pos[1] + 0.1, pos[2]), quat)
            if sKey in keys and keys[sKey] & p.KEY_WAS_TRIGGERED:
                pos, quat = self.get_robot_pose()
                self.reset_robot_pose((pos[0] - 0.1, pos[1], pos[2]), quat)
            if dKey in keys and keys[dKey] & p.KEY_WAS_TRIGGERED:
                pos, quat = self.get_robot_pose()
                self.reset_robot_pose((pos[0], pos[1] - 0.1, pos[2]), quat)
            while self.paused:
                sleep(0.1)
                keys = p.getKeyboardEvents()
                if spaceKey in keys and keys[spaceKey] & p.KEY_WAS_TRIGGERED:
                    self.paused = not self.paused
                if xKey in keys and keys[xKey] & p.KEY_IS_DOWN:
                    break
        if self.real_time:
            time.sleep(max(0, self.timestep - (time.time() - self.
                last_wall_time)))
        self.last_wall_time = time.time()
        self.time += self.timestep
        p.stepSimulation()
        for name, ps in self.pressure_sensors.items():
            ps.filter_step()

    def set_gravity(self, active):
        if active:
            p.setGravity(0, 0, -9.81)
        else:
            p.setGravity(0, 0, 0)
        self.gravity = active

    def set_robot_pose(self, position, orientation):
        p.resetBasePositionAndOrientation(self.robot_index, position,
            orientation)

    def reset_simulation(self):
        p.resetSimulation()
        self.load_models()
    <mask token>

    def reset_robot_pose_rpy(self, position, rpy):
        quat = tf.transformations.quaternion_from_euler(*rpy)
        self.reset_robot_pose(position, quat)

    def get_robot_pose(self):
        (x, y, z), (qx, qy, qz, qw) = p.getBasePositionAndOrientation(self.
            robot_index)
        return (x, y, z), (qx, qy, qz, qw)
    <mask token>

    def get_link_pose(self, link_name):
        return p.getLinkState(self.robot_index, self.links[link_name])[0]
    <mask token>
    <mask token>
    <mask token>


class Joint:

    def __init__(self, joint_index, body_index, ft=False):
        self.joint_index = joint_index
        self.body_index = body_index
        joint_info = p.getJointInfo(self.body_index, self.joint_index)
        self.name = joint_info[1].decode('utf-8')
        self.type = joint_info[2]
        self.max_force = joint_info[10]
        self.max_velocity = joint_info[11]
        self.lowerLimit = joint_info[8]
        self.upperLimit = joint_info[9]
        self.damping = joint_info[6]
        self.friction = joint_info[7]
        self.ft = ft

    def reset_position(self, position, velocity):
        p.resetJointState(self.body_index, self.joint_index, targetValue=
            position, targetVelocity=velocity)

    def disable_motor(self):
        p.setJointMotorControl2(self.body_index, self.joint_index,
            controlMode=p.POSITION_CONTROL, targetPosition=0,
            targetVelocity=0, positionGain=0.1, velocityGain=0.1, force=0)

    def set_position(self, position):
        p.setJointMotorControl2(self.body_index, self.joint_index, p.
            POSITION_CONTROL, targetPosition=position, force=self.max_force -
            self.friction, maxVelocity=self.max_velocity)

    def get_state(self):
        position, velocity, forces, applied_torque = p.getJointState(self.
            body_index, self.joint_index)
        return position, velocity, forces, applied_torque

    def get_position(self):
        position, velocity, forces, applied_torque = self.get_state()
        return position

    def get_velocity(self):
        position, velocity, forces, applied_torque = self.get_state()
        return velocity

    def get_applied_torque(self):
        position, velocity, forces, applied_torque = self.get_state()
        return applied_torque

    def get_torque(self):
        if self.ft:
            position, velocity, forces, applied_torque = self.get_state()
            return forces[5]
        else:
            print('Force Torque sensor not activated!')
            return None


class PressureSensor:

    def __init__(self, name, joint_index, body_index, cutoff, order):
        self.joint_index = joint_index
        self.name = name
        self.body_index = body_index
        nyq = 240 * 0.5
        normalized_cutoff = cutoff / nyq
        self.filter_b, self.filter_a = signal.butter(order,
            normalized_cutoff, btype='low')
        self.filter_state = signal.lfilter_zi(self.filter_b, 1)
        self.unfiltered = 0
        self.filtered = [0]

    def filter_step(self):
        self.unfiltered = p.getJointState(self.body_index, self.joint_index)[2
            ][2] * -1
        self.filtered, self.filter_state = signal.lfilter(self.filter_b,
            self.filter_a, [self.unfiltered], zi=self.filter_state)

    def get_force(self):
        return max(self.unfiltered, 0), max(self.filtered[0], 0)

#!/usr/bin/env python3
import math
import sys
import os
import time
import pybullet as p
from time import sleep
import time

import rospy
import tf
from scipy import signal
import pybullet_data
import rospkg
from transforms3d.quaternions import quat2mat

from wolfgang_pybullet_sim.terrain import Terrain
import numpy as np


class Simulation:
    def __init__(self, gui, urdf_path=None, foot_link_names=[], terrain=False, field=True, joints_ft=False,
                 robot="wolfgang"):
        self.gui = gui
        self.paused = False
        self.gravity = True
        self.terrain_on = terrain
        self.field_on = field
        self.urdf_path = urdf_path
        self.foot_link_names = foot_link_names
        self.joints_ft = joints_ft
        self.robot = robot

        # config values
        self.start_position = [0, 0, 0.43]
        self.start_orientation = p.getQuaternionFromEuler((0, 0.25, 0))
        if self.robot == "wolfgang":
            self.initial_joints_positions = {"LAnklePitch": -30, "LAnkleRoll": 0, "LHipPitch": 30, "LHipRoll": 0,
                                             "LHipYaw": 0, "LKnee": 60, "RAnklePitch": 30, "RAnkleRoll": 0,
                                             "RHipPitch": -30, "RHipRoll": 0, "RHipYaw": 0, "RKnee": -60,
                                             "LShoulderPitch": 0, "LShoulderRoll": 0, "LElbow": 45, "RShoulderPitch": 0,
                                             "RShoulderRoll": 0, "RElbow": -45, "HeadPan": 0, "HeadTilt": 0}
        elif self.robot in ["op2", "robotis_op2"]:
            self.initial_joints_positions = {"l_ankle_pitch": 0, "l_ankle_roll": 0, "l_hip_pitch": 0, "l_hip_roll": 0,
                                             "l_hip_yaw": 0, "l_knee": 0, "r_ankle_pitch": 0, "r_ankle_roll": 0,
                                             "r_hip_pitch": 0, "r_hip_roll": 0, "r_hip_yaw": 0, "r_knee": 0,
                                             "l_sho_pitch": 0, "l_sho_roll": 0, "LElbow": 0, "r_sho_pitch": 0,
                                             "r_sho_roll": 0, "RElbow": 0, "head_pan": 0, "head_tilt": 0}
            self.foot_link_names = ["l_foot", "r_foot"]
        elif self.robot == "sigmaban":
            self.start_orientation = p.getQuaternionFromEuler((0, 0.0, 0))
            self.initial_joints_positions = {"left_ankle_pitch": 0, "left_ankle_roll": 0, "left_hip_pitch": 0,
                                             "left_hip_roll": 0, "left_hip_yaw": 0, "left_knee": 0,
                                             "right_ankle_pitch": 0, "right_ankle_roll": 0, "right_hip_pitch": 0,
                                             "right_hip_roll": 0, "right_hip_yaw": 0, "right_knee": 0,
                                             "left_shoulder_pitch": 0, "left_shoulder_roll": 0, "LElbow": 0,
                                             "right_shoulder_pitch": 0, "right_shoulder_roll": 0, "RElbow": 0,
                                             "head_yaw": 0, "head_pitch": 0}
        else:
            print(f"robot {self.robot} not known")
            quit(0)
        # Instantiating Bullet
        if self.gui:
            self.client_id = p.connect(p.GUI)
        else:
            self.client_id = p.connect(p.DIRECT)
        if self.gravity:
            p.setGravity(0, 0, -9.81)
        self.time = 0
        # disable debug interface, only show robot
        p.configureDebugVisualizer(p.COV_ENABLE_GUI, False)

        # Engine parameters
        # time step should be at 240Hz (due to pyBullet documentation)
        self.timestep = 1 / 240
        # standard parameters seem to be best. leave them like they are
        # p.setPhysicsEngineParameter(fixedTimeStep=self.timestep, numSubSteps=1)
        # no real time, as we will publish own clock, but we have option to switch to real_time by waiting
        self.real_time = False
        p.setRealTimeSimulation(0)
        self.last_wall_time = time.time()

        self.load_models()

    def load_models(self):
        print("load models")
        # Load floor
        self.terrain_index = None
        self.plane_index = None
        if self.terrain_on:
            self.max_terrain_height = 0.01
            self.terrain = Terrain(self.max_terrain_height)
            self.terrain_index = self.terrain.id
        else:
            p.setAdditionalSearchPath(pybullet_data.getDataPath())  # needed for plane.urdf
            self.plane_index = p.loadURDF('plane.urdf')

        self.field_index = None
        if self.field_on:
            # Load field
            rospack = rospkg.RosPack()
            path = os.path.join(rospack.get_path('wolfgang_pybullet_sim'), 'models')
            p.setAdditionalSearchPath(path)  # needed to find field model
            self.field_index = p.loadURDF('field/field.urdf')

        # Load robot, deactivate all self collisions
        if self.robot in ["wolfgang", "sigmaban"]:
            # we have a better inertia estimation from onshape in our model
            flags = p.URDF_USE_SELF_COLLISION + p.URDF_USE_INERTIA_FROM_FILE
        else:
            # most other URDFs from the internet have issues with their inertia values
            flags = p.URDF_USE_SELF_COLLISION

        if self.urdf_path is None:
            # use wolfgang as standard
            rospack = rospkg.RosPack()
            if self.robot == "op2":
                self.urdf_path = rospack.get_path("robotis_op2_description") + "/urdf/robot.urdf"
            elif self.robot == "sigmaban":
                self.urdf_path = rospack.get_path("sigmaban_description") + "/urdf/robot.urdf"
            else:
                self.urdf_path = rospack.get_path("wolfgang_description") + "/urdf/robot.urdf"
        self.robot_index = p.loadURDF(self.urdf_path, self.start_position, self.start_orientation, flags=flags)

        # Retrieving joints and foot pressure sensors
        self.joints = {}
        self.pressure_sensors = {}
        self.links = {}

        # Collecting the available joints
        link_index = 0
        for i in range(p.getNumJoints(self.robot_index)):
            joint_info = p.getJointInfo(self.robot_index, i)
            name = joint_info[1].decode('utf-8')
            type = joint_info[2]
            # we can get the links by seeing where the joint is attached
            self.links[joint_info[12].decode('utf-8')] = link_index
            link_index += 1
            # see if it is a joint
            if type == 0:
                if self.joints_ft:
                    p.enableJointForceTorqueSensor(self.robot_index, i)
                # remember joint if its revolute (0) and not fixed (4)
                self.joints[name] = Joint(i, self.robot_index, ft=self.joints_ft)
            elif name in ["LLB", "LLF", "LRF", "LRB", "RLB", "RLF", "RRF", "RRB"]:
                p.enableJointForceTorqueSensor(self.robot_index, i)
                self.pressure_sensors[name] = PressureSensor(name, i, self.robot_index, 10, 5)

        for linkA in self.links.keys():
            for linkB in self.links.keys():
                p.setCollisionFilterPair(self.robot_index, self.robot_index, self.links[linkA],
                                         self.links[linkB], 0)
        hip_group = []
        foot_group = []
        if self.robot in ("wolfgang", "op2", "robotis_op2"):
            # set collisions for hip and ankle towards each other, otherwise stand up is not realistic
            hip_group = ["torso", "r_hip_1", "r_hip_2", "l_hip_1", "l_hip_2"]
            foot_group = ["r_ankle", "r_foot", "l_ankle", "l_foot"]
        elif self.robot in ("sigmaban"):
            hip_group = ["mx106_block_mir_1", "u_block_1", "right_knee_1", "left_knee_1", "mx106_block_2", "u_block_2"]
            foot_group = ["tibia_1", "mx106_block_1", "right_foot_cleat_back_left", "mx106_block_mir_2",
                          "left_foot_cleat_front_right", "tibia_2"]
        for hip_link_index in hip_group:
            for foot_link_index in foot_group:
                p.setCollisionFilterPair(self.robot_index, self.robot_index, self.links[hip_link_index],
                                         self.links[foot_link_index], 1)
        # reset robot to initial position
        self.reset()

    def apply_force(self, link_id, force, position):
        """
        Applies an external force to a position on a link.
        :param link_id: link index or -1 for base link (int)
        :param force: direction and amount of applied force (vec3)
        :param position: where on the link the force should be applied (vec3)
        """
        p.applyExternalForce(self.robot_index, link_id, force, position, flags=p.WORLD_FRAME)

    def set_foot_dynamics(self, contact_damping, contact_stiffness, joint_damping, lateral_friction=1,
                          spinning_friction=1, rolling_friction=1, restitution=0):
        # set dynamic values for all links and ground
        for link_name in self.links.keys():
            if link_name in ["llb", "llf", "lrf", "lrb", "rlb", "rlf", "rrf",
                             "rrb"] or link_name in self.foot_link_names:
                # print(p.getLinkState(self.robot_index, self.links[link_name]))
                p.changeDynamics(self.robot_index, self.links[link_name],
                                 lateralFriction=lateral_friction,
                                 spinningFriction=spinning_friction,
                                 rollingFriction=rolling_friction,
                                 contactDamping=contact_damping,
                                 contactStiffness=contact_stiffness,
                                 jointDamping=joint_damping,
                                 restitution=restitution)
        if self.plane_index:
            p.changeDynamics(self.plane_index, -1, lateralFriction=lateral_friction, spinningFriction=spinning_friction,
                             rollingFriction=rolling_friction, restitution=restitution, contactDamping=contact_damping,
                             contactStiffness=contact_stiffness, jointDamping=joint_damping)
        if self.field_index:
            p.changeDynamics(self.field_index, -1, lateralFriction=lateral_friction, spinningFriction=spinning_friction,
                             rollingFriction=rolling_friction, restitution=restitution, contactDamping=contact_damping,
                             contactStiffness=contact_stiffness, jointDamping=joint_damping)
        if self.terrain_index:
            p.changeDynamics(self.terrain_index, -1, lateralFriction=lateral_friction,
                             spinningFriction=spinning_friction,
                             rollingFriction=rolling_friction, restitution=restitution, contactDamping=contact_damping,
                             contactStiffness=contact_stiffness, jointDamping=joint_damping)

    def set_filter_params(self, cutoff, order):
        for i in range(p.getNumJoints(self.robot_index)):
            joint_info = p.getJointInfo(self.robot_index, i)
            name = joint_info[1].decode('utf-8')
            if name in ["LLB", "LLF", "LRF", "LRB", "RLB", "RLF", "RRF", "RRB"]:
                self.pressure_sensors[name] = PressureSensor(name, i, self.robot_index, cutoff, order)

    def reset(self):
        # set joints to initial position
        for name in self.joints:
            joint = self.joints[name]
            try:
                pos_in_rad = math.radians(self.initial_joints_positions[name])
            except KeyError:
                pos_in_rad = 0
            joint.reset_position(pos_in_rad, 0)
            joint.set_position(pos_in_rad)

        # reset body pose and velocity
        p.resetBasePositionAndOrientation(self.robot_index, self.start_position, self.start_orientation)
        p.resetBaseVelocity(self.robot_index, [0, 0, 0], [0, 0, 0])

    def step(self):
        # get keyboard events if gui is active
        if self.gui:
            # reset if R-key was pressed
            rKey = ord('r')
            # gravity
            nKey = ord('n')
            # single step
            xKey = ord('x')
            # real time
            tKey = ord('t')
            # randomize terrain
            fKey = ord('f')
            # pause
            spaceKey = p.B3G_SPACE
            # rotate robot for testing
            jKey = ord('j')
            kKey = ord('k')
            lKey = ord('l')
            # move robot for testing
            qKey = ord('q')
            aKey = ord('a')
            sKey = ord('s')
            dKey = ord('d')
            keys = p.getKeyboardEvents()
            if rKey in keys and keys[rKey] & p.KEY_WAS_TRIGGERED:
                self.reset()
            if spaceKey in keys and keys[spaceKey] & p.KEY_WAS_TRIGGERED:
                self.paused = not self.paused
            if nKey in keys and keys[nKey] & p.KEY_WAS_TRIGGERED:
                self.set_gravity(not self.gravity)
            if tKey in keys and keys[tKey] & p.KEY_WAS_TRIGGERED:
                self.real_time = not self.real_time
            if fKey in keys and keys[fKey] & p.KEY_WAS_TRIGGERED:
                # generate new terain
                self.terrain.randomize(0.01)
            if jKey in keys and keys[jKey] & p.KEY_WAS_TRIGGERED:
                pos, rpy = self.get_robot_pose_rpy()
                self.reset_robot_pose_rpy(pos, (rpy[0] + math.radians(30), rpy[1], rpy[2]))
            if kKey in keys and keys[kKey] & p.KEY_WAS_TRIGGERED:
                pos, rpy = self.get_robot_pose_rpy()
                self.reset_robot_pose_rpy(pos, (rpy[0], rpy[1] + math.radians(30), rpy[2]))
            if lKey in keys and keys[lKey] & p.KEY_WAS_TRIGGERED:
                pos, rpy = self.get_robot_pose_rpy()
                self.reset_robot_pose_rpy(pos, (rpy[0], rpy[1], rpy[2] + math.radians(30)))
            if qKey in keys and keys[qKey] & p.KEY_WAS_TRIGGERED:
                pos, quat = self.get_robot_pose()
                self.reset_robot_pose((pos[0] + 0.1, pos[1], pos[2]), quat)
            if aKey in keys and keys[aKey] & p.KEY_WAS_TRIGGERED:
                pos, quat = self.get_robot_pose()
                self.reset_robot_pose((pos[0], pos[1] + 0.1, pos[2]), quat)
            if sKey in keys and keys[sKey] & p.KEY_WAS_TRIGGERED:
                pos, quat = self.get_robot_pose()
                self.reset_robot_pose((pos[0] - 0.1, pos[1], pos[2]), quat)
            if dKey in keys and keys[dKey] & p.KEY_WAS_TRIGGERED:
                pos, quat = self.get_robot_pose()
                self.reset_robot_pose((pos[0], pos[1] - 0.1, pos[2]), quat)
            # block until pause is over
            while self.paused:
                # sleep a bit to not block a whole CPU core while waiting
                sleep(0.1)
                keys = p.getKeyboardEvents()
                if spaceKey in keys and keys[spaceKey] & p.KEY_WAS_TRIGGERED:
                    self.paused = not self.paused
                if xKey in keys and keys[xKey] & p.KEY_IS_DOWN:
                    break

        if self.real_time:
            # wait till one timestep has actually passed in real time
            time.sleep(max(0, self.timestep - (time.time() - self.last_wall_time)))
        self.last_wall_time = time.time()
        self.time += self.timestep
        p.stepSimulation()
        for name, ps in self.pressure_sensors.items():
            ps.filter_step()

    def set_gravity(self, active):
        if active:
            p.setGravity(0, 0, -9.81)
        else:
            p.setGravity(0, 0, 0)
        self.gravity = active

    def set_robot_pose(self, position, orientation):
        p.resetBasePositionAndOrientation(self.robot_index, position, orientation)

    def reset_simulation(self):
        p.resetSimulation()
        self.load_models()

    def reset_robot_pose(self, position, orientation):
        # reset body pose and velocity
        p.resetBasePositionAndOrientation(self.robot_index, position, orientation)
        p.resetBaseVelocity(self.robot_index, [0, 0, 0], [0, 0, 0])
        # we need to reset all joints to, otherwise they still have velocity
        for name in self.joints:
            joint = self.joints[name]
            p.resetJointState(joint.body_index, joint.joint_index, 0, 0)

    def reset_robot_pose_rpy(self, position, rpy):
        quat = tf.transformations.quaternion_from_euler(*rpy)
        self.reset_robot_pose(position, quat)

    def get_robot_pose(self):
        (x, y, z), (qx, qy, qz, qw) = p.getBasePositionAndOrientation(self.robot_index)
        return (x, y, z), (qx, qy, qz, qw)

    def get_robot_pose_rpy(self):
        (x, y, z), (qx, qy, qz, qw) = p.getBasePositionAndOrientation(self.robot_index)
        (roll, pitch, yaw) = p.getEulerFromQuaternion((qx, qy, qz, qw))
        return (x, y, z), (roll, pitch, yaw)

    def get_link_pose(self, link_name):
        return p.getLinkState(self.robot_index, self.links[link_name])[0]

    def get_robot_velocity(self):
        # these are in world coordinate frame
        (vx, vy, vz), (vr, vp, vy) = p.getBaseVelocity(self.robot_index)
        # rotate to robot frame
        _, (x, y, z, w) = self.get_robot_pose()
        # rotation matrix
        M = quat2mat((w, x, y, z))
        # velocities as vector
        v = np.array([vr, vp, vy]).T
        angular_vel_robot_frame = np.matmul(M.T, v)
        return (vx, vy, vz), angular_vel_robot_frame

    def get_joint_names(self):
        names = []
        for name in self.joints:
            joint = self.joints[name]
            names.append(joint.name)
        return names

    def get_joint_position(self, name):
        return self.joints[name].get_position()


class Joint:
    def __init__(self, joint_index, body_index, ft=False):
        self.joint_index = joint_index
        self.body_index = body_index
        joint_info = p.getJointInfo(self.body_index, self.joint_index)
        self.name = joint_info[1].decode('utf-8')
        self.type = joint_info[2]
        self.max_force = joint_info[10]
        self.max_velocity = joint_info[11]
        self.lowerLimit = joint_info[8]
        self.upperLimit = joint_info[9]
        self.damping = joint_info[6]
        self.friction = joint_info[7]
        self.ft = ft

    def reset_position(self, position, velocity):
        p.resetJointState(self.body_index, self.joint_index, targetValue=position, targetVelocity=velocity)
        # self.disable_motor()

    def disable_motor(self):
        p.setJointMotorControl2(self.body_index, self.joint_index,
                                controlMode=p.POSITION_CONTROL, targetPosition=0, targetVelocity=0,
                                positionGain=0.1, velocityGain=0.1, force=0)

    def set_position(self, position):
        p.setJointMotorControl2(self.body_index, self.joint_index,
                                p.POSITION_CONTROL,
                                targetPosition=position, force=self.max_force - self.friction,
                                maxVelocity=self.max_velocity)

    def get_state(self):
        position, velocity, forces, applied_torque = p.getJointState(self.body_index, self.joint_index)
        return position, velocity, forces, applied_torque

    def get_position(self):
        position, velocity, forces, applied_torque = self.get_state()
        return position

    def get_velocity(self):
        position, velocity, forces, applied_torque = self.get_state()
        return velocity

    def get_applied_torque(self):
        position, velocity, forces, applied_torque = self.get_state()
        return applied_torque

    def get_torque(self):
        if self.ft:
            position, velocity, forces, applied_torque = self.get_state()
            # todo this guesses z is the correct axis, but we dont know
            return forces[5]
        else:
            print("Force Torque sensor not activated!")
            return None


class PressureSensor:
    def __init__(self, name, joint_index, body_index, cutoff, order):
        self.joint_index = joint_index
        self.name = name
        self.body_index = body_index
        nyq = 240 * 0.5  # nyquist frequency from simulation frequency
        normalized_cutoff = cutoff / nyq  # cutoff freq in hz
        self.filter_b, self.filter_a = signal.butter(order, normalized_cutoff, btype='low')
        self.filter_state = signal.lfilter_zi(self.filter_b, 1)
        self.unfiltered = 0
        self.filtered = [0]

    def filter_step(self):
        self.unfiltered = p.getJointState(self.body_index, self.joint_index)[2][2] * -1
        self.filtered, self.filter_state = signal.lfilter(self.filter_b, self.filter_a, [self.unfiltered],
                                                          zi=self.filter_state)

    def get_force(self):
        return max(self.unfiltered, 0), max(self.filtered[0], 0)