Skip to content

Risk profile v2 #196

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
khareyash05 wants to merge 4 commits into
base: main
Choose a base branch
from
Open

Risk profile v2 #196

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
4 commits
Select commit Hold shift + click to select a range
a64e163
feat: add risk-profile app
anjupathak03 Oct 9, 2025
2cde549
fix: use separate branches for application changes
anjupathak03 Oct 12, 2025
598d33e
feat: make application changes to replicate risk profiles
anjupathak03 Oct 12, 2025
e2b6b83
feat: add endpoint for schema compeletly changed
anjupathak03 Oct 12, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
17 changes: 17 additions & 0 deletions risk-profile/curl.sh
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,17 @@
# Body tests
curl http://localhost:8080/users-low-risk
curl http://localhost:8080/users-medium-risk
curl http://localhost:8080/users-medium-risk-with-addition
curl http://localhost:8080/users-high-risk-type
curl http://localhost:8080/users-high-risk-removal
curl http://localhost:8080/schema-completely-changed

# Status and Header tests
curl http://localhost:8080/status-change-high-risk
curl http://localhost:8080/content-type-change-high-risk
curl http://localhost:8080/header-change-medium-risk

# Combined tests
curl http://localhost:8080/status-body-change
curl http://localhost:8080/header-body-change
curl http://localhost:8080/status-body-header-change
3 changes: 3 additions & 0 deletions risk-profile/go.mod
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,3 @@
module github.com/keploy/samples-go/risk-profile

go 1.24.2
168 changes: 168 additions & 0 deletions risk-profile/main.go
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,168 @@
package main

import (
"encoding/json"
"fmt"
"log"
"net/http"
"time"
)

type UserV1 struct {
ID int `json:"id"`
Name string `json:"name"`
Email string `json:"email"`
}

var originalUsers = []UserV1{
{ID: 1, Name: "Alice", Email: "alice@example.com"},
}

func getUsersLowRisk(w http.ResponseWriter, r *http.Request) {
w.Header().Set("Content-Type", "application/json")
user := originalUsers[0]
response := map[string]interface{}{
"id": user.ID,
"name": user.Name,
"email": user.Email,
"timestamp": time.Now().Unix(),
"phone": "9999988888",
}
json.NewEncoder(w).Encode(response)
}

func getUsersMediumRisk(w http.ResponseWriter, r *http.Request) {
w.Header().Set("Content-Type", "application/json")
user := originalUsers[0]
response := map[string]interface{}{
"id": user.ID,
"name": user.Name + "-Modified",
"email": user.Email,
"timestamp": time.Now().Unix(),
}
json.NewEncoder(w).Encode(response)
}

func getUsersMediumRiskWithAddition(w http.ResponseWriter, r *http.Request) {
w.Header().Set("Content-Type", "application/json")
user := originalUsers[0]
response := map[string]interface{}{
"id": user.ID,
"name": user.Name + "-Modified",
"email": user.Email,
"timestamp": time.Now().Unix(),
"phone": "9999988888",
}
json.NewEncoder(w).Encode(response)
}

func getUsersHighRiskType(w http.ResponseWriter, r *http.Request) {
w.Header().Set("Content-Type", "application/json")
user := originalUsers[0]
response := map[string]interface{}{
"id": "123",
"name": user.Name,
"email": user.Email,
"timestamp": time.Now().Unix(),
}
json.NewEncoder(w).Encode(response)
}

func getUsersHighRiskRemoval(w http.ResponseWriter, r *http.Request) {
w.Header().Set("Content-Type", "application/json")
user := originalUsers[0]
response := map[string]interface{}{
"id": user.ID,
"name": user.Name,
"timestamp": time.Now().Unix(),
}
json.NewEncoder(w).Encode(response)
}

func statusChangeHighRisk(w http.ResponseWriter, r *http.Request) {
w.Header().Set("Content-Type", "application/json")
w.WriteHeader(http.StatusAccepted)
response := map[string]interface{}{
"status": "OK",
"timestamp": time.Now().Unix(),
}
json.NewEncoder(w).Encode(response)
}

func contentTypeChangeHighRisk(w http.ResponseWriter, r *http.Request) {
w.Header().Set("Content-Type", "application/xml")
w.WriteHeader(http.StatusOK)
response := map[string]interface{}{
"message": "This is JSON.",
"timestamp": time.Now().Unix(),
}
json.NewEncoder(w).Encode(response)
}

func headerChangeMediumRisk(w http.ResponseWriter, r *http.Request) {
w.Header().Set("X-Custom-Header", "initial-value-456")
w.WriteHeader(http.StatusOK)
response := map[string]interface{}{
"status": "header test",
"timestamp": time.Now().Unix(),
}
json.NewEncoder(w).Encode(response)
}

func statusBodyChange(w http.ResponseWriter, r *http.Request) {
w.Header().Set("Content-Type", "application/json")
w.WriteHeader(http.StatusAccepted)
response := map[string]interface{}{
"message": "Status and body changed",
"timestamp": time.Now().UnixNano(),
}
json.NewEncoder(w).Encode(response)
}

func headerBodyChange(w http.ResponseWriter, r *http.Request) {
w.Header().Set("X-Transaction-ID", "txn-2")
w.Header().Set("Content-Type", "application/json")
response := map[string]interface{}{
"message": "Header and body changed",
"timestamp": time.Now().UnixNano(),
}
json.NewEncoder(w).Encode(response)
}

func statusBodyHeaderChange(w http.ResponseWriter, r *http.Request) {
w.Header().Set("X-Transaction-ID", "txn-2")
w.Header().Set("Content-Type", "application/json")
w.WriteHeader(http.StatusAccepted)
response := map[string]interface{}{
"message": "Status, body, and header changed",
"timestamp": time.Now().UnixNano(),
}
json.NewEncoder(w).Encode(response)
}

func schemaCompletelyChanged(w http.ResponseWriter, r *http.Request) {
w.Header().Set("Content-Type", "text/plain")
w.WriteHeader(http.StatusOK)
fmt.Fprintln(w, "This is a completely different, non-JSON response body.")
}

func main() {
log.Println("Application starting...")
http.HandleFunc("/users-low-risk", getUsersLowRisk)
http.HandleFunc("/users-medium-risk", getUsersMediumRisk)
http.HandleFunc("/users-medium-risk-with-addition", getUsersMediumRiskWithAddition)
http.HandleFunc("/users-high-risk-type", getUsersHighRiskType)
http.HandleFunc("/users-high-risk-removal", getUsersHighRiskRemoval)
http.HandleFunc("/status-change-high-risk", statusChangeHighRisk)
http.HandleFunc("/content-type-change-high-risk", contentTypeChangeHighRisk)
http.HandleFunc("/header-change-medium-risk", headerChangeMediumRisk)
http.HandleFunc("/status-body-change", statusBodyChange)
http.HandleFunc("/header-body-change", headerBodyChange)
http.HandleFunc("/status-body-header-change", statusBodyHeaderChange)
http.HandleFunc("/schema-completely-changed", schemaCompletelyChanged)
port := "8080"
log.Printf("Server starting on port %s...", port)
if err := http.ListenAndServe(fmt.Sprintf(":%s", port), nil); err != nil {
log.Fatalf("could not start server: %s\n", err)
}
}